diff --git a/wcs/nladmin-system/src/main/java/org/nl/config/mqtt/callback/SubsribeCallback.java b/wcs/nladmin-system/src/main/java/org/nl/config/mqtt/callback/SubsribeCallback.java index 43c1fa04..f29e79de 100644 --- a/wcs/nladmin-system/src/main/java/org/nl/config/mqtt/callback/SubsribeCallback.java +++ b/wcs/nladmin-system/src/main/java/org/nl/config/mqtt/callback/SubsribeCallback.java @@ -19,7 +19,7 @@ public class SubsribeCallback implements MqttCallback { @Override public void messageArrived(String topic, MqttMessage mqttMessage) throws Exception { - //接收到消息:先放队列,根据不同topic处理不同处理逻辑 + //接收到消息:先放队列,根据不同topic处理不同处理dd逻辑 System.out.println("接收到消息topic:"+topic+"——"+new String(mqttMessage.getPayload())); MsgPoolManager.hander(new MsgWorker(topic,new String(mqttMessage.getPayload()))); }