TRX преди 1 година
родител
ревизия
e848ccbb99
променени са 1 файла, в които са добавени 2 реда и са изтрити 2 реда
  1. 2 2
      src/main/java/com/zswl/dataservice/service/artemis/ArtemisListenerService.java

+ 2 - 2
src/main/java/com/zswl/dataservice/service/artemis/ArtemisListenerService.java

@@ -40,14 +40,14 @@ public class ArtemisListenerService {
     @JmsListener(destination = "/v1/gateway/#", containerFactory = MQConstant.TopicListenerContainerFactory)
     @JmsListener(destination = ".v1.gateway.#", containerFactory = MQConstant.TopicListenerContainerFactory)
     public void receiveGateWayMessage(Message message) {
-//        operationMessageService.handlerGateWayMessage(message);
+        operationMessageService.handlerGateWayMessage(message);
     }
 
     // 设备来的消息
     @JmsListener(destination = "/v1/device/#", containerFactory = MQConstant.TopicListenerContainerFactory)
     @JmsListener(destination = ".v1.device.#", containerFactory = MQConstant.TopicListenerContainerFactory)
     public void receiveDeviceMessage(Message message) {
-//        operationMessageService.handlerGateWayMessage(message);
+        operationMessageService.handlerGateWayMessage(message);
     }
 
     // 终端连接的消息