acknowledgeQos1Message method

bool acknowledgeQos1Message(
  1. MqttPublishMessage message
)

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