handlePublishReceived method

bool handlePublishReceived(
  1. MqttMessage? msg
)

Handles publish received messages during processing of QOS level 2 (Exactly once) messages. Returns true or false, depending on the success of message processing.

Implementation

bool handlePublishReceived(MqttMessage? msg) {
  final recvMsg = msg as MqttPublishReceivedMessage;
  final messageIdentifier = recvMsg.variableHeader.messageIdentifier;
  MqttLogger.log(
      'PublishingManager::handlePublishReceived - for message identifier $messageIdentifier');
  // If we've got a matching message, respond with a "ok release it for processing"
  if (publishedMessages.containsKey(messageIdentifier)) {
    final relMsg = MqttPublishReleaseMessage()
        .withMessageIdentifier(recvMsg.variableHeader.messageIdentifier);
    connectionHandler!.sendMessage(relMsg);
  }
  return true;
}