后处理消息

src/main/java/com/miniframe/aftercure/ActionMsg.java

@@ -25,6 +25,18 @@ public class ActionMsg {
      */
     private String action ;
 
+    /**
+     * 操作
+     */
+    private String img ;
+
+    public String getImg() {
+        return img;
+    }
+
+    public void setImg(String img) {
+        this.img = img;
+    }
 
     public String getUsrId() {
         return usrId;

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

@@ -1,7 +1,9 @@
 package com.miniframe.service.mq;
 
+import com.miniframe.aftercure.ActionMsg;
 import com.miniframe.core.ext.UtilTools;
 import com.miniframe.spring.mq.*;
+import com.miniframe.tools.XiJsonUtil;
 import com.miniframe.websocket.WebsocketEndPoint;
 import com.rabbitmq.client.Channel;
 import org.springframework.amqp.core.AcknowledgeMode;
@@ -92,8 +94,9 @@ 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.sendMessageToAllUsers(data);
+            point.sendMessageToUser(msg.getProId(),data);
             return true;
         }
     }