ClientHandler Class — netty Architecture

Source Code

handler/src/test/java/io/netty/handler/ssl/JdkDelegatingPrivateKeyMethodTest.java lines 497–527

    private static final class ClientHandler extends ChannelInboundHandlerAdapter {
        final Promise<String> resultPromise;

        ClientHandler(Promise<String> resultPromise) {
            this.resultPromise = resultPromise;
        }

        @Override
        public void channelActive(ChannelHandlerContext ctx) {
            // Send single byte message once connection is established
            ByteBuf message = Unpooled.copiedBuffer("R", CharsetUtil.UTF_8);
            ctx.writeAndFlush(message);
        }

        @Override
        public void channelRead(ChannelHandlerContext ctx, Object msg) {
            // Close connection after receiving echo
            if (msg instanceof ByteBuf) {
                ByteBuf bytes = (ByteBuf) msg;
                resultPromise.setSuccess(bytes.toString(CharsetUtil.UTF_8));
                bytes.release();
                ctx.close();
            }
        }

        @Override
        public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) {
            resultPromise.tryFailure(cause);
            ctx.close();
        }
    }