添加显示控制

device-manager/src/main/java/com/mortals/xhx/base/system/message/impl/MessageProducer.java

@@ -65,6 +65,7 @@ public class MessageProducer implements IMessageProduceService, RabbitMessageSer
         args.put("x-message-ttl", 86400000);
         Queue rabbitQueue = new Queue(queue, true, false, false, args);
         DirectExchange directExchange = new DirectExchange(exchange);
+
         rabbitAdmin.declareQueue(rabbitQueue);
         rabbitAdmin.declareBinding(
                 BindingBuilder.bind(rabbitQueue)

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DeviceComsumersRegisterService.java

 package com.mortals.xhx.daemon.applicationservice;
 
+import com.alibaba.fastjson.JSON;
 import com.mortals.framework.springcloud.service.IApplicationStartedService;
 import com.mortals.xhx.base.framework.listener.DirectDynamicListener;
 import com.mortals.xhx.base.system.message.impl.MessageProducer;
@@ -11,11 +12,14 @@ import com.mortals.xhx.module.device.service.DeviceService;
 import com.mortals.xhx.module.platform.service.PlatformService;
 import com.mortals.xhx.module.product.service.ProductService;
 import lombok.extern.slf4j.Slf4j;
+import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Component;
 import org.springframework.util.ObjectUtils;
 
+import java.util.Collection;
+
 /**
  * 初始化设备消费者注册
  *
@@ -40,12 +44,19 @@ public class DeviceComsumersRegisterService implements IApplicationStartedServic
     private SendTaskThreadPool sendTaskThreadPool;
     @Autowired
     private DirectDynamicListener directDynamicListener;
+    @Autowired
+    private RabbitTemplate rabbitTemplate;
 
     @Override
     public void start() {
         log.info("初始化发送线程数量");
         sendTaskThreadPool.init(20);
         log.info("服务端消息队列初始化服务开始..");
+
+        Collection<String> rabbitmqQueues = rabbitTemplate.expectedQueueNames();
+        log.info("queues:{}", JSON.toJSONString(rabbitmqQueues));
+
+
         deviceService.find(new DeviceEntity())
                 .stream()
                 .filter(f -> !ObjectUtils.isEmpty(platformService.get(f.getPlatformId())))

device-manager/src/main/java/com/mortals/xhx/daemon/applicationservice/DeviceMsgComsumerStartedService.java

@@ -57,9 +57,6 @@ public class DeviceMsgComsumerStartedService implements IApplicationStartedServi
     @Autowired
     private ICacheService cacheService;
 
-//    @Autowired
-//    private IMessageProduceService messageProduceService;
-
     protected volatile ExecutorService consumersExecutor;