实时点位主题 更改

portal-service-infrastructure/src/main/java/com/hfln/portal/infrastructure/config/MqttConfig.java

@@ -117,9 +117,10 @@ public class MqttConfig {
                 TopicConstants.TOPIC_DAS_EVENT,
                 TopicConstants.TOPIC_DAS_ALARM_EVENT,
                 TopicConstants.TOPIC_DAS_DEV_STATUS,
-                TopicConstants.TOPIC_DAS_EXIST,
+                TopicConstants.TOPIC_DAS_EXIST
+//                ,
 //                TopicConstants.TOPIC_DAS_REALTIME_POS
-                TopicConstants.TOPIC_DAS_REALTIME_POS_2
+//                TopicConstants.TOPIC_DAS_REALTIME_POS_2
 
                 , TopicConstants.TOPIC_MQTT_CLIENT_CONNECT
         };
@@ -128,7 +129,7 @@ public class MqttConfig {
                 new MqttPahoMessageDrivenChannelAdapter(clientId, mqttClientFactory(), topics);
         adapter.setCompletionTimeout(5000);
         adapter.setConverter(new DefaultPahoMessageConverter());
-        adapter.setQos(2, 2, 0, 0, 0
+        adapter.setQos(2, 2, 0, 0
         , 2);
         adapter.setOutputChannel(inputChannel());
         adapter.setTaskScheduler(taskScheduler());

portal-service-infrastructure/src/main/java/com/hfln/portal/infrastructure/mqtt/MqttSubHandle.java

@@ -97,9 +97,9 @@ public class MqttSubHandle {
                 case "alarm_event":
                     subDasAlarmEvent(topic, payload);
                     break;
-                case "realtime_pos":
-                    subDasRealtimePos(topic, payload);
-                    break;
+//                case "realtime_pos":
+//                    subDasRealtimePos(topic, payload);
+//                    break;
                 case "dev_status":
                     subDasDevStatus(topic, payload);
                     break;