acknowledgeQos1Message method
Manually acknowledge a received QOS 1 message. Has no effect if manuallyAcknowledgeQos1 is not in force or the message is not awaiting a QOS 1 acknowledge. Returns true if an acknowledgement is sent to the broker.
Implementation
bool acknowledgeQos1Message(MqttPublishMessage message) {
final messageIdentifier = message.variableHeader!.messageIdentifier;
if (awaitingManualAcknowledge.keys.contains(messageIdentifier) &&
manuallyAcknowledgeQos1) {
final ackMsg =
MqttPublishAckMessage().withMessageIdentifier(messageIdentifier);
connectionHandler!.sendMessage(ackMsg);
awaitingManualAcknowledge.remove(messageIdentifier);
return true;
}
return false;
}