恢复消息监听器功能

registration-center/src/main/java/com/huimv/center/listener/DeviceListener.java

@@ -48,7 +48,7 @@ public class DeviceListener {
      * @Date        : 2022/6/22
      * @Time        : 20:11
      */
-//    @RabbitListener(queues = Const.QUEUE_DEVICE_REGISTERED)
+    @RabbitListener(queues = Const.QUEUE_DEVICE_REGISTERED)
     @RabbitHandler
     @Transactional
     public void processDeviceRegisteredFlow(Map askMap) throws ParseException {
@@ -73,7 +73,7 @@ public class DeviceListener {
      * @Date        : 2022/6/22       
      * @Time        : 20:13
      */
-//    @RabbitListener(queues = Const.QUEUE_DEVICE_UNREGISTERED)
+    @RabbitListener(queues = Const.QUEUE_DEVICE_UNREGISTERED)
     @RabbitHandler
     @Transactional
     public void processDeviceUnregisteredFlow(Map askMap) throws ParseException {
@@ -95,7 +95,7 @@ public class DeviceListener {
      * @Date        : 2022/6/22
      * @Time        : 20:15
      */
-//    @RabbitListener(queues = Const.QUEUE_DEVICE_ANSWER)
+    @RabbitListener(queues = Const.QUEUE_DEVICE_ANSWER)
     @RabbitHandler
     @Transactional
     public void processDeviceAnswer(Map askMap) throws ParseException {
@@ -120,7 +120,7 @@ public class DeviceListener {
      * @Date        : 2022/6/30       
      * @Time        : 18:11
      */
-//    @RabbitListener(queues = Const.QUEUE_ASK_CMD)
+    @RabbitListener(queues = Const.QUEUE_ASK_CMD)
     @RabbitHandler
     public void processAskCmd(Map askMap) throws ParseException {
         String askCmd = askMap.get("askCmd").toString();
@@ -128,7 +128,7 @@ public class DeviceListener {
         bizRawDataServiceImpl.addRawData(askCmd);
     }
 
-//    @RabbitListener(queues = Const.QUEUE_ASK_CMD)
+    @RabbitListener(queues = Const.QUEUE_ASK_CMD)
     @RabbitHandler
     public void processSyncFarmDeviceRegister(Map askMap) throws ParseException {
         // 添加原始数据信息

registration-center/src/main/java/com/huimv/center/listener/SysBaseConfigListener.java

@@ -38,7 +38,7 @@ public class SysBaseConfigListener {
     private BizBaseAreaService bizBaseAreaService;
 
 
-//    @RabbitListener(queues = Const.QUEUE_SYNC_SYS_CONFIG)
+    @RabbitListener(queues = Const.QUEUE_SYNC_SYS_CONFIG)
     @RabbitHandler
     public void syncSysBaseConfig(Map<String,String> params) throws ParseException {