Fixes issue aciidgh#46

noelportugal · Mar 13, 2022 · 3c02caf · 3c02caf
1 parent 6667e19
commit 3c02caf
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/SwiftMQTT/SwiftMQTT/MQTTSession.swift b/SwiftMQTT/SwiftMQTT/MQTTSession.swift
@@ -157,7 +157,9 @@ open class MQTTSession {
         case let pubAck as MQTTPubAck:
             callSuccessCompletionBlock(for: pubAck.messageID)
         case let publishPacket as MQTTPublishPacket:
-            sendPubAck(for: publishPacket.messageID)
+            if publishPacket.message.QoS != .atMostOnce {
+                sendPubAck(for: publishPacket.messageID)
+            }
             let message = MQTTMessage(publishPacket: publishPacket)
             delegateQueue.async { [weak self] in
                 self?.delegate?.mqttDidReceive(message: message, from: self!)