Improve exception handle of transaction check service (#1783)

apache · Feb 24, 2020 · d15234c · d15234c
1 parent 35c3888
commit d15234c
Showing 1 changed file with 1 addition and 2 deletions.
diff --git a/...in/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java b/...in/java/org/apache/rocketmq/broker/transaction/queue/TransactionalMessageServiceImpl.java
@@ -240,8 +240,7 @@ public void check(long transactionTimeout, int transactionCheckMax,
                     transactionalMessageBridge.updateConsumeOffset(opQueue, newOpOffset);
                 }
             }
-        } catch (Exception e) {
-            e.printStackTrace();
+        } catch (Throwable e) {
             log.error("Check error", e);
         }