Commit c9dee362 by huangfusuper

修复RPCserver调用失败后无法写回的BUG

parent 911edd8d
...@@ -74,6 +74,7 @@ public class NettyPluginServerHandler extends SimpleChannelInboundHandler<Plugin ...@@ -74,6 +74,7 @@ public class NettyPluginServerHandler extends SimpleChannelInboundHandler<Plugin
@Override @Override
public void run(PluginRpcRequestPacket msg,ChannelHandlerContext ctx) { public void run(PluginRpcRequestPacket msg,ChannelHandlerContext ctx) {
PluginRpcResponsePacket rpcResponsePacket = new PluginRpcResponsePacket(); PluginRpcResponsePacket rpcResponsePacket = new PluginRpcResponsePacket();
rpcResponsePacket.setRequestId(msg.getRequestId());
try { try {
Map<String, Object> serverPoll = pluginServerFactory.getServerPoll(); Map<String, Object> serverPoll = pluginServerFactory.getServerPoll();
String jobName = msg.getJobName(); String jobName = msg.getJobName();
......
Markdown is supported
0% or
You are about to add 0 people to the discussion. Proceed with caution.
Finish editing this message first!
Please register or to comment