🐛 fix a bug

sanshengshui · sanshengshui · commit 791ef5ab63ee · 2021-03-15T23:51:22.000+08:00
diff --git a/IOT-Guide-MQTT/src/main/java/iot/technology/mqtt/MqttTransportHandler.java b/IOT-Guide-MQTT/src/main/java/iot/technology/mqtt/MqttTransportHandler.java
@@ -108,7 +108,9 @@ private void processDevicePublish(ChannelHandlerContext ctx, MqttPublishMessage
             } else if (topicName.equals(MqttTopics.DEVICE_ATTRIBUTES_REQUEST_TOPIC_PREFIX)) {
                 JsonMqttAdaptor.convertToMsg(GET_ATTRIBUTES_REQUEST, mqttMsg);
             }
-            ctx.writeAndFlush(createMqttPubAckMsg(msgId));
+            if (msgId > 0) {
+                ctx.writeAndFlush(createMqttPubAckMsg(msgId));
+            }
         } catch (AdaptorException e) {
             ctx.close();
         }
@@ -177,7 +179,7 @@ private void processUnsubscribe(ChannelHandlerContext ctx, MqttUnsubscribeMessag
                         break;
 
                 }
-            }catch (AdaptorException e) {
+            } catch (AdaptorException e) {
 
             }
         }

Original file line number	Diff line number	Diff line change
`@@ -108,7 +108,9 @@ private void processDevicePublish(ChannelHandlerContext ctx, MqttPublishMessage`
`108`	`108`	`} else if (topicName.equals(MqttTopics.DEVICE_ATTRIBUTES_REQUEST_TOPIC_PREFIX)) {`
`109`	`109`	`JsonMqttAdaptor.convertToMsg(GET_ATTRIBUTES_REQUEST, mqttMsg);`
`110`	`110`	`}`
`111`		`- ctx.writeAndFlush(createMqttPubAckMsg(msgId));`
	`111`	`+ if (msgId > 0) {`
	`112`	`+ ctx.writeAndFlush(createMqttPubAckMsg(msgId));`
	`113`	`+ }`
`112`	`114`	`} catch (AdaptorException e) {`
`113`	`115`	`ctx.close();`
`114`	`116`	`}`
`@@ -177,7 +179,7 @@ private void processUnsubscribe(ChannelHandlerContext ctx, MqttUnsubscribeMessag`
`177`	`179`	`break;`
`178`	`180`
`179`	`181`	`}`
`180`		`- }catch (AdaptorException e) {`
	`182`	`+ } catch (AdaptorException e) {`
`181`	`183`
`182`	`184`	`}`
`183`	`185`	`}`