public void start()

in impl/src/main/java/org/apache/rocketmq/remoting/impl/netty/NettyRemotingClient.java [84:102]

• 17 lines of code
• 1 McCabe index (conditional complexity)

    public void start() {
        super.start();

        this.clientBootstrap.group(this.ioGroup).channel(socketChannelClass)
            .handler(new ChannelInitializer<SocketChannel>() {
                @Override
                public void initChannel(SocketChannel ch) {
                    ch.pipeline().addLast(workerGroup,
                        new Decoder(),
                        new Encoder(),
                        new IdleStateHandler(clientConfig.getConnectionChannelReaderIdleSeconds(),
                            clientConfig.getConnectionChannelWriterIdleSeconds(), clientConfig.getConnectionChannelIdleSeconds()),
                        new ClientConnectionHandler(),
                        new RemotingCommandDispatcher());
                }
            });

        applyOptions(clientBootstrap);
    }