解决设备下发消息

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

@@ -10,6 +10,7 @@ import com.mortals.xhx.module.device.model.DeviceEntity;
 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 com.mortals.xhx.thread.DeviceDownMsgThread;
 import com.mortals.xhx.thread.DeviceUpdateComsumerThread;
 import com.mortals.xhx.thread.SendThirdPartyThread;
 import lombok.extern.slf4j.Slf4j;
@@ -46,6 +47,8 @@ public class DeviceComsumersRegisterService implements IApplicationStartedServic
     private DeviceUpdateComsumerThread deviceUpdateComsumerThread;
     @Autowired
     private SendThirdPartyThread sendThirdPartyThread;
+    @Autowired
+    private DeviceDownMsgThread deviceDownMsgThread;
 
     @Override
     public void start() {
@@ -53,8 +56,11 @@ public class DeviceComsumersRegisterService implements IApplicationStartedServic
         sendTaskThreadPool.init(20);
         log.info("设备更新消费线程启动");
         deviceUpdateComsumerThread.start();
-        log.info("设备更新消费线程启动");
+        log.info("第三方发送线程启动");
         sendThirdPartyThread.start();
+        log.info("消息下发发送线程启动");
+        deviceDownMsgThread.start();
+
         log.info("服务端消息队列初始化服务开始..");
 
         deviceService.find(new DeviceEntity())