add:接入mqtt(td:项目启停时设备信号读写2)

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())));
     }