Fixed issue #362

2017-10-20 12:27:50 +02:00
parent ba2b8b44d3
commit 3293478dd7
1 changed files with 1 additions and 1 deletions
@@ -844,7 +844,7 @@ public class ProtocolProcessor {
            grantedQoSLevels.add(req.qualityOfService().value());
        }

-        MqttFixedHeader fixedHeader = new MqttFixedHeader(MqttMessageType.SUBACK, false, AT_LEAST_ONCE, false, 0);
+        MqttFixedHeader fixedHeader = new MqttFixedHeader(MqttMessageType.SUBACK, false, AT_MOST_ONCE, false, 0);
        MqttSubAckPayload payload = new MqttSubAckPayload(grantedQoSLevels);
        return new MqttSubAckMessage(fixedHeader, from(messageId), payload);
    }