修改线程初始化数量

device-manager/src/main/java/com/mortals/xhx/base/framework/config/RabbitConfig.java

@@ -11,7 +11,6 @@ import org.springframework.amqp.rabbit.AsyncRabbitTemplate;
 import org.springframework.amqp.rabbit.config.SimpleRabbitListenerContainerFactory;
 import org.springframework.amqp.rabbit.connection.CachingConnectionFactory;
 import org.springframework.amqp.rabbit.connection.ConnectionFactory;
-import org.springframework.amqp.rabbit.connection.CorrelationData;
 import org.springframework.amqp.rabbit.core.RabbitAdmin;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.rabbit.listener.DirectMessageListenerContainer;
@@ -23,7 +22,6 @@ import org.springframework.boot.autoconfigure.amqp.SimpleRabbitListenerContainer
 import org.springframework.context.annotation.Bean;
 import org.springframework.context.annotation.Configuration;
 import org.springframework.core.annotation.Order;
-import org.springframework.util.ObjectUtils;
 
 @Configuration
 @Order(1)

device-manager/src/main/java/com/mortals/xhx/busiz/web/DeviceApiController.java

@@ -1065,7 +1065,7 @@ public class DeviceApiController {
                     serverInfo.setEventUrl(productEntity.getEventUrl());
                 }
             } else {
-                log.info("资源部署异常！");
+                log.info("资源为空！");
             }
 
         } else {

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

@@ -60,7 +60,7 @@ public class DeviceComsumersRegisterService implements IApplicationStartedServic
     @Override
     public void start() {
         log.info("初始化发送线程数量");
-        sendTaskThreadPool.init(20);
+        sendTaskThreadPool.init(6);
 
         //判断是否为
         if (!ObjectUtils.isEmpty(deviceUpdateComsumerIp)) {