receive method
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!');
}