diff --git a/src/main/java/com/loafle/overflow/container/server/RPCServerHandler.java b/src/main/java/com/loafle/overflow/container/server/RPCServerHandler.java index e19afb5..a979214 100644 --- 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 { logger.debug("Error", e); error = e; } - + if (!requestCodec.hasResponse()) { + return; + } byte[] responseBytes = requestCodec.response(reply, error); ctx.channel().writeAndFlush(responseBytes); } else {