|
@@ -39,7 +39,7 @@ public class RabbitMqProducerUtil {
|
|
|
String messageId = UUID.randomUUID().toString();
|
|
|
String jsonObject = JSONObject.toJSONString(content);
|
|
|
log.info("开始发送Mq消息,messageId:{},消息队列:{},消息内容:{}",messageId, queue,jsonObject);
|
|
|
- rabbitTemplate.convertAndSend(queue, content, message -> {
|
|
|
+ rabbitTemplate.convertAndSend(queue, jsonObject, message -> {
|
|
|
message.getMessageProperties().setMessageId(messageId);
|
|
|
return message;
|
|
|
}, new CorrelationData(messageId));
|