rocketmq-commits mailing list archives

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_yewu@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;
                 }