sendMessageToReceiver method

void sendMessageToReceiver(
  1. IMessageReceiver? receiver,
  2. 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')});
}