@@ -143,6 +143,7 @@ public void notifyGroup(String groupId, String unitId, String transactionType, i
143143 txLogger .txTrace (
144144 groupId , unitId , "notify group > transaction type: {}, state: {}." , transactionType , state );
145145 if (globalContext .isDTXTimeout ()) {
146+ txLogger .trace (groupId , unitId , Transactions .TE , "dtx timeout." );
146147 throw new LcnBusinessException ("dtx timeout." );
147148 }
148149 state = reliableMessenger .notifyGroup (groupId , state );
@@ -153,7 +154,7 @@ public void notifyGroup(String groupId, String unitId, String transactionType, i
153154 dtxExceptionHandler .handleNotifyGroupMessageException (Arrays .asList (groupId , state , unitId , transactionType ), e );
154155 } catch (LcnBusinessException e ) {
155156 // 关闭事务组失败
156- dtxExceptionHandler .handleNotifyGroupBusinessException (Arrays .asList (groupId , state , unitId , transactionType ), e . getCause () );
157+ dtxExceptionHandler .handleNotifyGroupBusinessException (Arrays .asList (groupId , state , unitId , transactionType ), e );
157158 }
158159 txLogger .txTrace (groupId , unitId , "notify group exception state {}." , state );
159160 }
0 commit comments