提交

amos-boot-system-tzs/amos-boot-module-tzs-biz/src/main/java/com/yeejoin/amos/boot/module/tzs/biz/listener/AmosMqttListener.java

@@ -18,7 +18,8 @@ public class AmosMqttListener extends EmqxListener {
     IEquipmentCategoryService equipmentCategoryService;
 
     @Override
-    public void processMessage(String topic, MqttMessage mqttMessage){
+    public void processMessage(String topic, MqttMessage mqttMessage) {
+        System.out.println(topic + "已收到：准备生成监管码或96333电梯识别码");
         byte[] payload = mqttMessage.getPayload();
         String str = new String(payload);
         String msg = JSON.parse(str).toString();