public void invokeAsync()

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

• 9 lines of code
• 3 McCabe index (conditional complexity)

    public void invokeAsync(final String address, final RemotingCommand request, final AsyncHandler asyncHandler,
        final long timeoutMillis) {

        final Channel channel = this.clientChannelManager.createIfAbsent(address);
        if (channel != null && channel.isActive()) {
            this.invokeAsyncWithInterceptor(channel, request, asyncHandler, timeoutMillis);
        } else {
            this.clientChannelManager.closeChannel(address, channel);
        }
    }