mq 捕获异常

src/main/java/com/docus/server/collection/receiver/MzZyMqReceiver.java

@@ -30,8 +30,13 @@ public class MzZyMqReceiver {
     @JmsIbmListener(destination = "TJ_createDepartment")
     public void revCreateDepartment(String message){
         log.info("注册科室 队列接收信息：{}",message);
-        DeptDto deptDto= MzZyParser.parseCreateDept(message);
-        powerDeptService.register(deptDto);
+        try {
+            DeptDto deptDto= MzZyParser.parseCreateDept(message);
+            powerDeptService.register(deptDto);
+        }catch (Exception ex){
+            log.error("处理注册科室 队列接收信息:{},出现异常:{}",message,ex.getMessage());
+        }
+
     }
 
 
@@ -43,8 +48,13 @@ public class MzZyMqReceiver {
     @JmsIbmListener(destination = "TJ_updateDepartment")
     public void revUpdateDepartment(String message){
         log.info("变更科室 队列接收信息：{}",message);
-        DeptDto deptDto=MzZyParser.parseUpdateDept(message);
-        powerDeptService.register(deptDto);
+        try {
+            DeptDto deptDto=MzZyParser.parseUpdateDept(message);
+            powerDeptService.register(deptDto);
+        }catch (Exception ex){
+            log.error("处理变更科室 队列接收信息:{},出现异常:{}",message,ex.getMessage());
+        }
+
     }
 
 
@@ -55,8 +65,13 @@ public class MzZyMqReceiver {
     @JmsIbmListener(destination = "TJ_createPractitioner")
     public void revCreatePractitioner(String message){
         log.info("人员注册 队列接收信息：{}",message);
-        UserDto userDto=MzZyParser.parseCreateUser(message);
-        powerUserService.register(userDto);
+        try {
+            UserDto userDto=MzZyParser.parseCreateUser(message);
+            powerUserService.register(userDto);
+        }catch (Exception ex){
+            log.error("处理人员注册 队列接收信息:{},出现异常:{}",message,ex.getMessage());
+        }
+
     }
 
 
@@ -67,7 +82,12 @@ public class MzZyMqReceiver {
     @JmsIbmListener(destination = "TJ_updatePractitioner")
     public void revUpdatePractitioner(String message){
         log.info("人员变更 队列接收信息：{}",message);
-        UserDto userDto=MzZyParser.parseUpdateUser(message);
-        powerUserService.register(userDto);
+        try {
+            UserDto userDto=MzZyParser.parseUpdateUser(message);
+            powerUserService.register(userDto);
+        }catch (Exception ex){
+            log.error("处理人员注册 队列接收信息:{},出现异常:{}",message,ex.getMessage());
+        }
+
     }
 }