anna/IM-server-new
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

mqtt proto version error

Browse Source
This commit is contained in:
heavyrian2012
2022-11-18 21:27:18 +08:00
parent b4d163e144
commit ab8ae9d0c9
1 changed files with 1 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files
broker/src/main/java/io/netty/handler/codec/mqtt/MqttDecoder.java
+1 -1
View File
@@ -534,7 +534,7 @@ public final class MqttDecoder extends ReplayingDecoder<MqttDecoder.DecoderState
final MqttProperties willProperties; final MqttProperties willProperties;
if (mqttConnectVariableHeader.isWillFlag()) { if (mqttConnectVariableHeader.isWillFlag()) {
if (mqttVersion.protocolLevel() <= MqttVersion.MQTT_5.protocolLevel()) { if (mqttVersion.protocolLevel() >= MqttVersion.MQTT_5.protocolLevel()) {
final Result<MqttProperties> propertiesResult = decodeProperties(buffer); final Result<MqttProperties> propertiesResult = decodeProperties(buffer);
willProperties = propertiesResult.value; willProperties = propertiesResult.value;
numberOfBytesConsumed += propertiesResult.numberOfBytesConsumed; numberOfBytesConsumed += propertiesResult.numberOfBytesConsumed;