后处理消息

src/main/java/com/miniframe/service/mq/CaeMQ.java

@@ -94,9 +94,14 @@ public class CaeMQ extends CaeViewMFMqDynamic {
         @Override
         public boolean handle(String data, long deliveryTag, Map<String, Object> headers, Channel channel) throws Exception {
 //            System.out.println("Queue : "+getAMQPConsumerQueue(headers)+", Data : "+ data);
-            ActionMsg msg= XiJsonUtil.jsonToPojo(data, ActionMsg.class);
-            WebsocketEndPoint point =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");
-            point.sendMessageToUser(msg.getProId(),data);
+           try {
+               ActionMsg msg= XiJsonUtil.jsonToPojo(data, ActionMsg.class);
+               WebsocketEndPoint point =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");
+               point.sendMessageToUser(msg.getProId(),data);
+           }catch (Exception e){
+               e.printStackTrace();
+           }
+
             return true;
         }
     }