ing

2018-04-23 21:48:50 +09:00 · 2018-04-23 21:48:50 +09:00 · eb46396d4d
commit eb46396d4d
parent 3a1cbe46c1
1 changed files with 3 additions and 1 deletions
--- a/src/main/java/com/loafle/overflow/container/server/RPCServerHandler.java
+++ b/src/main/java/com/loafle/overflow/container/server/RPCServerHandler.java
@ -44,7 +44,9 @@ public class RPCServerHandler extends SimpleChannelInboundHandler<SocketFrame> {
        logger.debug("Error", e);
        error = e;
      }
-
+      if (!requestCodec.hasResponse()) {
+        return;
+      }
      byte[] responseBytes = requestCodec.response(reply, error);
      ctx.channel().writeAndFlush(responseBytes);
    } else {