Prechádzať zdrojové kódy

修改发送mq消息bug

lixing 4 rokov pred
rodič
commit
3f16ba7a3a

+ 1 - 1
src/main/java/com/persagy/dmp/starter/alarm/communication/mq/sender/MessageSender.java

@@ -35,6 +35,6 @@ public abstract class MessageSender {
      */
     public void sendMessage(DmpMessage message, String routingKey) {
         log.info("向rabbitMQ发送消息,message:" + JSONObject.toJSON(message).toString());
-        rabbitTemplate.convertAndSend(exchange, routingKey, message);
+        rabbitTemplate.convertAndSend(exchange, routingKey, JSONObject.toJSON(message).toString());
     }
 }

+ 11 - 0
src/main/java/com/persagy/dmp/starter/alarm/util/StringUtil.java

@@ -3,6 +3,9 @@ package com.persagy.dmp.starter.alarm.util;
 import com.alibaba.fastjson.JSONObject;
 import org.apache.commons.lang3.StringUtils;
 
+import java.util.HashMap;
+import java.util.Map;
+
 /**
  * @description:
  * @author: lixing
@@ -17,4 +20,12 @@ public class StringUtil {
         }
         return t.newInstance();
     }
+
+    public static void main(String[] args) {
+        Map<String, Object> map = new HashMap<>();
+        map.put("a", "1");
+        map.put("b", "2");
+
+        JSONObject obj = (JSONObject) JSONObject.toJSON(map);
+    }
 }