修改bug

smqtt-common/src/main/java/io/github/quickmsg/common/channel/MqttChannel.java

@@ -249,6 +249,7 @@ public class MqttChannel {
             } else {
                 return mqttChannel.write(Mono.just(mqttMessage));
             }
+        }
         private int getMessageId(MqttMessage mqttMessage) {
             Object object = mqttMessage.variableHeader();
             if (object instanceof MqttPublishVariableHeader) {

smqtt-core/src/main/java/io/github/quickmsg/core/protocol/CommonProtocol.java

@@ -70,7 +70,7 @@ public class CommonProtocol implements Protocol<MqttMessage> {
                                     subscribeTopics.stream()
                                             .map(subscribeTopic -> subscribeTopic.getMqttChannel()
                                                     .write(MessageUtils.wrapPublishMessage(msg, subscribeTopic.getQoS(),
-                                                            subscribeTopic.getMqttChannel().generateMessageId()), true)
+                                                            subscribeTopic.getMqttChannel().generateMessageId()), subscribeTopic.getQoS().value() > 0)
                                             ).collect(Collectors.toList()))
                                     .then(mqttChannel.cancelRetry(MqttMessageType.PUBREC, id))
                                     .then(mqttChannel.write(MqttMessageBuilder.buildPublishComp(id), false));