sendMessageToReceiver method

Future sendMessageToReceiver(
  1. IMessageReceiver? receiver,
  2. MessageEnvelope? message
)

Sends a message to a receiver.

  • receiver receiver of the message.
  • message message to be sent.

Implementation

Future sendMessageToReceiver(
    IMessageReceiver? receiver, MessageEnvelope? message) async {
  var correlationId = message != null ? message.correlation_id : null;
  if (message == null || receiver == null) {
    logger.warn(correlationId, 'Message was skipped.');
    return;
  }

  try {
    await _receiver!.receiveMessage(message, this);
  } catch (ex) {
    logger.error(
        correlationId, ex as Exception, 'Failed to process the message');
  }
}