websocket 消息转发

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

@@ -106,7 +106,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("收到mq 消息");
             try {
                 ActionMsg msg= XiJsonUtil.jsonToPojo(data, ActionMsg.class);
                 WebsocketEndPoint point =  (WebsocketEndPoint) UtilTools.getBean("websocketEndPoint");

src/main/java/com/miniframe/websocket/WebsocketEndPoint.java

@@ -119,6 +119,7 @@ public class WebsocketEndPoint extends TextWebSocketHandler {
 			try {
 				TextMessage message = new TextMessage(contents);
 				session.sendMessage(message);
+				System.out.println("websocket发生 消息");
 			} catch (IOException e) {
 				//e.printStackTrace();
 			}