From d15234c683216db9e0f77578d4adffd3e42406eb Mon Sep 17 00:00:00 2001 From: huangli Date: Mon, 24 Feb 2020 09:01:31 +0800 Subject: [PATCH] Improve exception handle of transaction check service (#1783) --- .../transaction/queue/TransactionalMessageServiceImpl.java | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java index 71b575ee..f7ba2e38 100644 --- a/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java +++ b/broker/src/main/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java @@ -240,8 +240,7 @@ public class TransactionalMessageServiceImpl implements TransactionalMessageServ transactionalMessageBridge.updateConsumeOffset(opQueue, newOpOffset); } } - } catch (Exception e) { - e.printStackTrace(); + } catch (Throwable e) { log.error("Check error", e); } -- GitLab