eolivelli commented on a change in pull request #1286: WIP - Implement directly ChannelOutboundHandlerAdapter in BookieProtoEncoding#ResponseEncoder URL: https://github.com/apache/bookkeeper/pull/1286#discussion_r176586775
########## File path: bookkeeper-server/src/main/java/org/apache/bookkeeper/proto/BookieProtoEncoding.java ########## @@ -452,20 +454,24 @@ protected void decode(ChannelHandlerContext ctx, Object msg, List<Object> out) t } @Override - protected void encode(ChannelHandlerContext ctx, Object msg, List<Object> out) - throws Exception { + public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception { if (LOG.isTraceEnabled()) { LOG.trace("Encode response {} to channel {}.", msg, ctx.channel()); } if (msg instanceof BookkeeperProtocol.Response) { - out.add(repV3.encode(msg, ctx.alloc())); + ctx.write(repV3.encode(msg, ctx.alloc()), promise); } else if (msg instanceof BookieProtocol.Response) { - out.add(repPreV3.encode(msg, ctx.alloc())); + ctx.write(repPreV3.encode(msg, ctx.alloc()), promise); } else { LOG.error("Invalid response to encode to {}: {}", ctx.channel(), msg.getClass().getName()); - out.add(msg); + ctx.write(msg, promise); } } + + @Override + public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception { + LOG.error("Generic error while encoding response", cause); + } Review comment: Will drop ---------------------------------------------------------------- This is an automated message from the Apache Git Service. To respond to the message, please log on GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org With regards, Apache Git Services