receiveMessage method

  1. @override
Future receiveMessage(
  1. MessageEnvelope envelope,
  2. IMessageQueue queue
)
override

Receives incoming message from the queue.

  • envelope an incoming message
  • queue a queue where the message comes from

See MessageEnvelope See IMessageQueue

Implementation

@override
Future receiveMessage(MessageEnvelope envelope, IMessageQueue queue) async {
  await _callback(envelope, queue);
}