huangxingxing 2 سال پیش
والد
کامیت
39882a3184
1فایلهای تغییر یافته به همراه1 افزوده شده و 1 حذف شده
  1. 1 1
      src/main/java/com/miniframe/service/mq/CaeMQ.java

+ 1 - 1
src/main/java/com/miniframe/service/mq/CaeMQ.java

@@ -93,7 +93,7 @@ public class CaeMQ extends CaeViewMFMqDynamic {
     public static class CaeMqOp implements IMFMqOp {
         @Override
         public boolean handle(String data, long deliveryTag, Map<String, Object> headers, Channel channel) throws Exception {
-//            System.out.println("Queue : "+getAMQPConsumerQueue(headers)+", Data : "+ data);
+            System.out.println("Queue : "+getAMQPConsumerQueue(headers)+", Data : "+ data);
             try {
                 ActionMsg msg= XiJsonUtil.jsonToPojo(data, ActionMsg.class);
                 WebsocketEndPoint point =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");