Modified the log level of RocketMQProducerMessageHandler.
@@ -184,8 +184,10 @@ public class RocketMQProducerMessageHandler extends AbstractMessageHandler
sendResult = this.send(mqMessage, this.messageQueueSelector,
message.getHeaders(), message);
}
- log.info("the message has sent,message={},sendResult={}", mqMessage,
+ if(log.isDebugEnabled()) {
+ log.debug("the message has sent,message={},sendResult={}", mqMessage,
sendResult);
+ }
if (sendResult == null
|| !SendStatus.SEND_OK.equals(sendResult.getSendStatus())) {
log.error("message send fail.SendStatus is not OK.the message={}",
