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