handlePublishReceived method
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;
}