From b3a95c0310a72a7775be5253cbeb26ab11a88e21 Mon Sep 17 00:00:00 2001 From: heavyrain2012 Date: Thu, 21 Nov 2019 10:24:16 +0800 Subject: [PATCH] update --- .../src/main/java/io/moquette/spi/impl/ProtocolProcessor.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java index 4ed5eea9..18b488de 100755 --- a/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java +++ b/broker/src/main/java/io/moquette/spi/impl/ProtocolProcessor.java @@ -142,7 +142,7 @@ public class ProtocolProcessor { String clientId = payload.clientIdentifier(); LOG.info("Processing CONNECT message. CId={}, username={}", clientId, payload.userName()); - if (msg.variableHeader().version() <= MqttVersion.MQTT_3_1_1.protocolLevel() || + if (msg.variableHeader().version() < MqttVersion.MQTT_3_1_1.protocolLevel() || msg.variableHeader().version() >= MqttVersion.Wildfire_Max.protocolLevel()) { MqttConnAckMessage badProto = connAck(CONNECTION_REFUSED_UNACCEPTABLE_PROTOCOL_VERSION);