添加巴中经开区windows shell

device-manager/src/main/java/com/mortals/xhx/module/device/service/impl/DeviceServiceImpl.java

@@ -224,7 +224,7 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
             //订阅上行队列
             // container.addQueueNames(Constant.UPLOAD_TOPIC + deviceCode);
 
-                restartMessageListener(Constant.UPLOAD_TOPIC + deviceCode);
+            restartMessageListener(Constant.UPLOAD_TOPIC + deviceCode);
 
 
             //新增设备通知第三方平台,先新增后激活
@@ -373,7 +373,7 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
                 messageProducer.queueAddAndBinds(QueueKey.DEFAULT_EXCHANGE, Constant.UPLOAD_TOPIC + entity.getDeviceCode(), Constant.UPLOAD_TOPIC + entity.getDeviceCode());
                 messageProducer.queueAddAndBinds(QueueKey.DEFAULT_EXCHANGE, Constant.DOWN_TOPIC + entity.getDeviceCode(), Constant.DOWN_TOPIC + entity.getDeviceCode());
 
-                    restartMessageListener(Constant.UPLOAD_TOPIC + entity.getDeviceCode());
+                restartMessageListener(Constant.UPLOAD_TOPIC + entity.getDeviceCode());
 
                 //监听上行队列
                 sendThirdParty(entity, productEntity, platformEntity, DeviceMethodEnum.UPDATE);
@@ -643,8 +643,8 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
             //激活设备，添加队列订阅
             //container.addQueueNames(Constant.UPLOAD_TOPIC + entity.getDeviceCode());
 
-                restartMessageListener(Constant.UPLOAD_TOPIC + entity.getDeviceCode());
-        
+            restartMessageListener(Constant.UPLOAD_TOPIC + entity.getDeviceCode());
+
             PlatformEntity platformEntity = platformService.getCache(entity.getPlatformId().toString());
             ProductEntity productEntity = productService.getCache(entity.getProductId().toString());
             sendThirdParty(entity, productEntity, platformEntity, DeviceMethodEnum.ADD);
@@ -760,7 +760,7 @@ public class DeviceServiceImpl extends AbstractCRUDCacheServiceImpl<DeviceDao, D
                 container.start();
             }
             container.start();
-        } catch (AppException e) {
+        } catch (Exception e) {
             log.error("重启消息监听失败", e);
             return false;
         }