setupClient() — netty Function Reference

Source Code

handler/src/test/java/io/netty/handler/ssl/SSLEngineTest.java lines 1955–1997

    private void setupClient(final BufferType type, final boolean delegate, final String host, final int port) {
        cb = new Bootstrap();
        cb.group(new MultiThreadIoEventLoopGroup(NioIoHandler.newFactory()));
        cb.channel(NioSocketChannel.class);
        cb.handler(new ChannelInitializer<Channel>() {
            @Override
            protected void initChannel(Channel ch) throws Exception {
                TestByteBufAllocator alloc = new TestByteBufAllocator(ch.config().getAllocator(), type);
                ch.config().setAllocator(alloc);

                ChannelPipeline p = ch.pipeline();

                final SslHandler sslHandler;
                if (!delegate) {
                    sslHandler = host != null ? clientSslCtx.newHandler(alloc, host, port) :
                            clientSslCtx.newHandler(alloc);
                } else {
                    sslHandler = host != null ? clientSslCtx.newHandler(alloc, host, port, delegatingExecutor) :
                            clientSslCtx.newHandler(alloc, delegatingExecutor);
                }
                clientSslHandshakeFuture = sslHandler.handshakeFuture();

                p.addLast(sslHandler);
                p.addLast(new MessageDelegatorChannelHandler(clientReceiver, clientLatch));
                p.addLast(new ChannelInboundHandlerAdapter() {
                    @Override
                    public void exceptionCaught(ChannelHandlerContext ctx, Throwable cause) throws Exception {
                        if (cause.getCause() instanceof SSLHandshakeException) {
                            clientException = cause.getCause();
                            clientLatch.countDown();
                        } else {
                            ctx.fireExceptionCaught(cause);
                        }
                    }

                    @Override
                    public void channelInactive(ChannelHandlerContext ctx) throws Exception {
                        clientLatch.countDown();
                    }
                });
            }
        });
    }