后处理消息

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

@@ -91,7 +91,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);
             WebsocketEndPoint point =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");
             point.sendMessageToAllUsers(data);
             return true;