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

解决完成提交未考虑返回结果的问题

Browse Source
This commit is contained in:
JerryYin 2019-01-08 14:52:01 +08:00
parent b35f972478
commit e17a8cb5fa
1 changed files with 5 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
raincat-manager/src/main/java/org/dromara/raincat/manager/netty/handler/NettyServerMessageHandler.java
View File

@ -25,6 +25,7 @@ import io.netty.handler.timeout.IdleState;
import io.netty.handler.timeout.IdleStateEvent;
import io.netty.util.ReferenceCountUtil;
import org.apache.commons.collections.CollectionUtils;
import org.apache.commons.lang3.StringUtils;
import org.dromara.raincat.common.enums.NettyMessageActionEnum;
import org.dromara.raincat.common.enums.NettyResultEnum;
import org.dromara.raincat.common.holder.LogUtil;
@ -129,6 +130,10 @@ public class NettyServerMessageHandler extends ChannelInboundHandlerAdapter {
txManagerService.updateTxTransactionItemStatus(txTransactionGroup.getId(),
item.getTaskKey(),
item.getStatus(), item.getMessage());
//异步的情况下，就不要返回消息了（key为空就是异步）
if(StringUtils.isNotBlank(hb.getKey())){
ctx.writeAndFlush(buildSendMessage(hb.getKey(), true));
}
}
break;
default: