[rocketmq-spring] branch master updated: [ISSUE #298] Too many warning info when consuming failed. (#302)

[jinrongtong]

This is an automated email from the ASF dual-hosted git repository.

jinrongtong pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-spring.git


The following commit(s) were added to refs/heads/master by this push:
     new 3cc554b  [ISSUE #298] Too many warning info when consuming failed. 
(#302)
3cc554b is described below

commit 3cc554b62f2f8a88efa38aecd3e52d985eb49654
Author: zhangjidi2016 <zhangjidi_y...@cmss.chinamobile.com>
AuthorDate: Tue Oct 27 20:45:32 2020 +0800

    [ISSUE #298] Too many warning info when consuming failed. (#302)
---
 .../rocketmq/spring/support/DefaultRocketMQListenerContainer.java     | 4 ++--
 1 file changed, 2 insertions(+), 2 deletions(-)

diff --git 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
index dff5e0c..89b9b91 100644
--- 
a/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
+++ 
b/rocketmq-spring-boot/src/main/java/org/apache/rocketmq/spring/support/DefaultRocketMQListenerContainer.java
@@ -355,7 +355,7 @@ public class DefaultRocketMQListenerContainer implements 
InitializingBean,
                     long costTime = System.currentTimeMillis() - now;
                     log.debug("consume {} cost: {} ms", messageExt.getMsgId(), 
costTime);
                 } catch (Exception e) {
-                    log.warn("consume message failed. messageExt:{}, 
error:{}", messageExt, e);
+                    log.warn("consume message failed. messageId:{}, topic:{}, 
reconsumeTimes:{}", messageExt.getMsgId(), messageExt.getTopic(), 
messageExt.getReconsumeTimes(), e);
                     
context.setDelayLevelWhenNextConsume(delayLevelWhenNextConsume);
                     return ConsumeConcurrentlyStatus.RECONSUME_LATER;
                 }
@@ -378,7 +378,7 @@ public class DefaultRocketMQListenerContainer implements 
InitializingBean,
                     long costTime = System.currentTimeMillis() - now;
                     log.info("consume {} cost: {} ms", messageExt.getMsgId(), 
costTime);
                 } catch (Exception e) {
-                    log.warn("consume message failed. messageExt:{}", 
messageExt, e);
+                    log.warn("consume message failed. messageId:{}, topic:{}, 
reconsumeTimes:{}", messageExt.getMsgId(), messageExt.getTopic(), 
messageExt.getReconsumeTimes(), e);
                     
context.setSuspendCurrentQueueTimeMillis(suspendCurrentQueueTimeMillis);
                     return ConsumeOrderlyStatus.SUSPEND_CURRENT_QUEUE_A_MOMENT;
                 }