修改代码

4dkankan-utils-mq/src/main/java/com/fdkankan/mq/util/RocketMQProducer.java

@@ -1,20 +1,23 @@
 package com.fdkankan.mq.util;
 
 import cn.hutool.core.util.StrUtil;
+import com.alibaba.fastjson.JSONObject;
+import lombok.extern.slf4j.Slf4j;
 import org.apache.rocketmq.client.producer.SendCallback;
 import org.apache.rocketmq.client.producer.SendResult;
 import org.apache.rocketmq.spring.core.RocketMQTemplate;
-import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.messaging.Message;
 import org.springframework.messaging.support.MessageBuilder;
 import org.springframework.stereotype.Component;
 
+import javax.annotation.Resource;
 import java.util.Objects;
 
 @Component
+@Slf4j
 public class RocketMQProducer {
 
-    @Autowired
+    @Resource
     RocketMQTemplate rocketMQTemplate;
 
     /**
@@ -161,12 +164,12 @@ public class RocketMQProducer {
         if(StrUtil.isNotEmpty(tag)){
             topic = topic + ":" + tag;
         }
+        log.info("MQ推送消息---topic:{},tag:{},key:{},msg:{}",topic,tag,key, JSONObject.toJSONString(body));
         MessageBuilder messageBuilder = MessageBuilder.withPayload(body);
         if(StrUtil.isNotEmpty(key)){
             messageBuilder.setHeader("KEYS", key);
         }
         Message message = messageBuilder.build();
-
         rocketMQTemplate.sendOneWay(topic, message);
     }