解决设备下发消息

device-manager/src/main/java/com/mortals/xhx/thread/DeviceDownMsgThread.java

@@ -62,7 +62,7 @@ public class DeviceDownMsgThread extends AbstractThread {
         log.info("DeviceDownMsgThread process");
         List<DeviceMsgReq> deviceMsgReqs = new ArrayList<>();
         while (true) {
-            DeviceMsgReq deviceMsgReq = cacheService.blpop(KEY_DEVICE_DOWN_MSG_QUEUE, 10, DeviceMsgReq.class);
+            DeviceMsgReq deviceMsgReq = cacheService.lpop(KEY_DEVICE_DOWN_MSG_QUEUE, DeviceMsgReq.class);
             if (ObjectUtils.isEmpty(deviceMsgReq)) {
                 log.info("deviceMsgReq:{}", deviceMsgReq == null);
                 break;

device-manager/src/main/java/com/mortals/xhx/thread/DeviceUpdateComsumerThread.java

@@ -41,7 +41,7 @@ public class DeviceUpdateComsumerThread extends AbstractThread {
         log.info("DeviceUpdateComsumerThread process");
         List<DeviceEntity> waitUpdateDeviceList = new ArrayList<>();
         while (true) {
-            DeviceEntity deviceEntity = cacheService.blpop(RedisKey.KEY_DEVICE_UPDATE_QUEUE, 10,DeviceEntity.class);
+            DeviceEntity deviceEntity = cacheService.lpop(RedisKey.KEY_DEVICE_UPDATE_QUEUE,DeviceEntity.class);
             if (ObjectUtils.isEmpty(deviceEntity)) {
                 log.info("deviceEntity:{}", deviceEntity == null);
                 break;