20201023 影子服务跟设备之间做状态同步

src/main/java/com/shadow/mq/nats/NatsMQ.java

@@ -48,8 +48,8 @@ public class NatsMQ {
         }
     }
 
-    public static String getTopicCMDs() {
-        return T_CMD + "." + getHostName(LocalAddressUtil.getIp());
+    public static String getTopicCMD() {
+        return T_CMD + ".*" ;
     }
 
     public static String getHostName(String ip) {

src/main/java/com/shadow/mq/nats/consumer/process/DeviceCmdMQ.java

@@ -71,7 +71,7 @@ public class DeviceCmdMQ implements NatsMQProcess {
 
     @Override
     public String getTopic() {
-        return NatsMQ.T_CMD;
+        return NatsMQ.getTopicCMD();
     }
 
 }