|
@@ -171,7 +171,7 @@ public class RocketMQProducer {
|
|
|
}
|
|
|
Message message = messageBuilder.build();
|
|
|
rocketMQTemplate.sendOneWay(topic, message);
|
|
|
- log.info("MQ推送成功---topic:{},tag:{},key:{},msg:{}",topic,tag,key, JSONObject.toJSONString(body));
|
|
|
+ log.info("MQ推送成功...");
|
|
|
}
|
|
|
|
|
|
/**
|
|
@@ -183,7 +183,7 @@ public class RocketMQProducer {
|
|
|
public void sendInOrder(String topic, String hashKey, Object body){
|
|
|
log.info("MQ推送消息---topic:{},hashKey:{},msg:{}",topic,hashKey, JSONObject.toJSONString(body));
|
|
|
rocketMQTemplate.syncSendOrderly(topic,body,hashKey);
|
|
|
- log.info("MQ推送成功---topic:{},hashKey:{},msg:{}",topic,hashKey, JSONObject.toJSONString(body));
|
|
|
+ log.info("MQ推送成功...");
|
|
|
}
|
|
|
|
|
|
}
|