receive abstract method

@override Future<MessageEnvelope?> receive(String? correlationId, int waitTimeout)

Receives an incoming message and removes it from the queue.

• correlationId (optional) transaction id to trace execution through call chain.
• waitTimeout a timeout in milliseconds to wait for a message to come. Return Future that receives a message Throws error.

Implementation

@override
Future<MessageEnvelope?> receive(String? correlationId, int waitTimeout);