Wraps a message callback into IMessageReceiver
Implements: IMessageReceiver
Description
The CallbackMessageReceiver class allows you to wrap message callbacks into IMessageReceiver.
Constructors
Creates an instance of the CallbackMessageReceiver.
CallbackMessageReceiver(Future<void> Function(MessageEnvelope envelope, IMessageQueue callback)
- callback: Future<void> Function(MessageEnvelope envelope, IMessageQueue - a callback function that shall be wrapped into IMessageReceiver
Instance methods
receiveMessage
Receives an incoming message from the queue.
See also MessageEnvelope, IMessageQueue
@override
Future receiveMessage(MessageEnvelope envelope, IMessageQueue queue)
- envelope: MessageEnvelope - incoming message
- queue: IMessageQueue - queue where the message comes from