sendMessageToReceiver method
void
sendMessageToReceiver(
- IMessageReceiver? receiver,
- MessageEnvelope? message
Implementation
void sendMessageToReceiver(
IMessageReceiver? receiver, MessageEnvelope? message) async {
var correlationId = message != null ? message.correlation_id : null;
if (message == null || receiver == null) {
_logger.warn(correlationId, 'MQTT message was skipped.');
return;
}
await _receiver!.receiveMessage(message, this).catchError((err) =>
{_logger.error(correlationId, err, 'Failed to process the message')});
}