receive abstract method

Future<MessageEnvelope?> receive(
  1. String? correlationId,
  2. 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 Throw error.


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