diff --git a/src/main/java/com/muyu/mqtt/MessageCallbackService.java b/src/main/java/com/muyu/mqtt/MessageCallbackService.java index 3fa3fa3..e514a7d 100644 --- a/src/main/java/com/muyu/mqtt/MessageCallbackService.java +++ b/src/main/java/com/muyu/mqtt/MessageCallbackService.java @@ -26,6 +26,7 @@ public class MessageCallbackService implements MqttCallback { } + @Override public void deliveryComplete(IMqttDeliveryToken token) { System.out.println("deliveryComplete---------" + token.isComplete());