From 92f2d03878c45740e0c8449260a7e7549f576b95 Mon Sep 17 00:00:00 2001
From: sunbufu <sunyoubufu@163.com>
Date: Mon, 28 Jun 2021 22:00:05 +0800
Subject: [PATCH] log exception stack

---
 .../impl/consumer/ConsumeMessageConcurrentlyService.java       | 3 ++-
 .../client/impl/consumer/ConsumeMessageOrderlyService.java     | 3 ++-
 2 files changed, 4 insertions(+), 2 deletions(-)

diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
index b37f8a63..e7b11a0c 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageConcurrentlyService.java
@@ -415,7 +415,8 @@ public class ConsumeMessageConcurrentlyService implements ConsumeMessageService
                     RemotingHelper.exceptionSimpleDesc(e),
                     ConsumeMessageConcurrentlyService.this.consumerGroup,
                     msgs,
-                    messageQueue);
+                    messageQueue,
+                    e);
                 hasException = true;
             }
             long consumeRT = System.currentTimeMillis() - beginTimestamp;
diff --git a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
index 130effad..5bd856e8 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/consumer/ConsumeMessageOrderlyService.java
@@ -491,7 +491,8 @@ public class ConsumeMessageOrderlyService implements ConsumeMessageService {
                                     RemotingHelper.exceptionSimpleDesc(e),
                                     ConsumeMessageOrderlyService.this.consumerGroup,
                                     msgs,
-                                    messageQueue);
+                                    messageQueue,
+                                    e);
                                 hasException = true;
                             } finally {
                                 this.processQueue.getConsumeLock().unlock();
-- 
GitLab