CallbackMessageReceiver constructor
CallbackMessageReceiver(
- Future<
void> callback(- MessageEnvelope envelope,
- IMessageQueue queue
Creates an instance of the CallbackMessageReceiver.
callback
a callback function that shall be wrapped into IMessageReceiver
Implementation
CallbackMessageReceiver(
Future<void> Function(MessageEnvelope envelope, IMessageQueue queue)
callback)
: _callback = callback;