test/Raincat
1
0
Fork 0
mirror of https://gitee.com/dromara/Raincat.git synced 2024-12-03 12:29:08 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

修复查询事务组状态失败的问题

Browse Source
This commit is contained in:
JerryYin 2018-08-21 10:55:41 +08:00
parent c1fd92246c
commit 610f73e0df
1 changed files with 1 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
raincat-core/src/main/java/com/raincat/core/service/message/NettyMessageServiceImpl.java
View File

@ -79,6 +79,7 @@ public class NettyMessageServiceImpl implements TxManagerMessageService {
heartBeat.setAction(NettyMessageActionEnum.GET_TRANSACTION_GROUP_STATUS.getCode()); heartBeat.setAction(NettyMessageActionEnum.GET_TRANSACTION_GROUP_STATUS.getCode());
TxTransactionGroup txTransactionGroup = new TxTransactionGroup(); TxTransactionGroup txTransactionGroup = new TxTransactionGroup();
txTransactionGroup.setId(txGroupId); txTransactionGroup.setId(txGroupId);
heartBeat.setTxTransactionGroup(txTransactionGroup);
final Object object = nettyClientMessageHandler.sendTxManagerMessage(heartBeat); final Object object = nettyClientMessageHandler.sendTxManagerMessage(heartBeat);
if (Objects.nonNull(object)) { if (Objects.nonNull(object)) {
return (Integer) object; return (Integer) object;