[20240315007-ZY20240401006]MES端实现设备MQ定向订阅和推送

client/src/main/java/org/gidea/scada/monitor/rabbit/template/MonitorRabbitTemplate.java

 package org.gidea.scada.monitor.rabbit.template;
 package org.gidea.scada.monitor.rabbit.template;
 
 
+import org.gidea.scada.monitor.rabbit.entity.MonitorMessage;
 import org.gidea.scada.monitor.rabbit.listener.MonitorRabbitListener;
 import org.gidea.scada.monitor.rabbit.listener.MonitorRabbitListener;
 import org.gidea.scada.monitor.utils.Constants;
 import org.gidea.scada.monitor.utils.Constants;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
 import org.springframework.amqp.rabbit.core.RabbitTemplate;
@@ -23,9 +24,9 @@ public class MonitorRabbitTemplate {
      * @param deviceId
      * @param deviceId
      * @param message
      * @param message
      */
      */
-    public void sendMessage(String deviceId, String message) {
+    public void sendMessage(String deviceId, MonitorMessage message) {
         rabbitListener.addDeviceListener(deviceId);
         rabbitListener.addDeviceListener(deviceId);
-        rabbitTemplate.convertAndSend(Constants.MonitorServiceName, message);
+        rabbitTemplate.convertAndSend(Constants.MonitorServiceName, message.toString());
     }
     }
 
 
 }
 }