receive method

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

Receive method are receives an incoming message and removes it from the _queue. Parameters:

  • 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 recive a message Throws error

Implementation

@override
Future<MessageEnvelope> receive(
    String? correlationId, int waitTimeout) async {
  // _checkOpened(correlationId);
  // var message = _toMessage(envelope);
  // if (message != null) {
  //   counters.incrementOne('_queue.' + name + '.received_messages');
  //   logger.debug(message.correlation_id, 'Received message %s via %s',
  //       [message, this]);
  // }
  // return message;
  throw Exception('Method "receive" are not supported!');
}