public NettyRemotingClient()

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

16 lines of code
3 McCabe index (conditional complexity)


    public NettyRemotingClient(final RemotingClientConfig clientConfig) {
        super(clientConfig);
        this.clientConfig = clientConfig;

        if (JvmUtils.isLinux() && this.clientConfig.isClientNativeEpollEnable()) {
            this.ioGroup = new EpollEventLoopGroup(clientConfig.getClientIoThreads(), ThreadUtils.newGenericThreadFactory("NettyClientEpollIoThreads",
                clientConfig.getClientWorkerThreads()));
            socketChannelClass = EpollSocketChannel.class;
        } else {
            this.ioGroup = new NioEventLoopGroup(clientConfig.getClientIoThreads(), ThreadUtils.newGenericThreadFactory("NettyClientNioIoThreads",
                clientConfig.getClientWorkerThreads()));
            socketChannelClass = NioSocketChannel.class;
        }

        this.clientChannelManager = new ClientChannelManager(clientBootstrap, clientConfig);

        this.workerGroup = new DefaultEventExecutorGroup(clientConfig.getClientWorkerThreads(),
            ThreadUtils.newGenericThreadFactory("NettyClientWorkerThreads", clientConfig.getClientWorkerThreads()));
    }