init

src/main/java/com/tuoren/forward/config/amqp/AmqpClient1.java

@@ -312,10 +312,11 @@ public class AmqpClient1 {
     				if(!StringUtils.isEmpty(config.getMqttTopic())) {
     					String[] topics = config.getMqttTopic().split(",");
     					for(String t : topics) {
-    						MqTick mt = mqTickMapper.selectOnlineByTopic(t);
-    						if(mt != null) {
-    							mqttUtil.pub(CommonConstant.MQTTUSER_PUBLISH_PREFIX+hospitalCode+"/"+t, mqttJson.toString());
-    						}
+//    						MqTick mt = mqTickMapper.selectOnlineByTopic(t);
+//    						if(mt != null) {
+//    							mqttUtil.pub(CommonConstant.MQTTUSER_PUBLISH_PREFIX+hospitalCode+"/"+t, mqttJson.toString());
+//    						}
+    						mqttUtil.pub(t, mqttJson.toString());
     					}
     				}else {
     					mqttUtil.pub(CommonConstant.MQTT_PUBLISH_PREFIX+hospitalCode, mqttJson.toString());

src/main/java/com/tuoren/forward/config/amqp/AmqpClient2.java

@@ -320,10 +320,11 @@ public class AmqpClient2 {
     				if(!StringUtils.isEmpty(config.getMqttTopic())) {
     					String[] topics = config.getMqttTopic().split(",");
     					for(String t : topics) {
-    						MqTick mt = mqTickMapper.selectOnlineByTopic(t);
-    						if(mt != null) {
-    							mqttUtil.pub(CommonConstant.MQTTUSER_PUBLISH_PREFIX+hospitalCode+"/"+t, mqttJson.toString());
-    						}
+//    						MqTick mt = mqTickMapper.selectOnlineByTopic(t);
+//    						if(mt != null) {
+//    							mqttUtil.pub(CommonConstant.MQTTUSER_PUBLISH_PREFIX+hospitalCode+"/"+t, mqttJson.toString());
+//    						}
+    						mqttUtil.pub(t, mqttJson.toString());
     					}
     				}else {
     					mqttUtil.pub(CommonConstant.MQTT_PUBLISH_PREFIX+hospitalCode, mqttJson.toString());