public void invokeOneWay()

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

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

    public void invokeOneWay(final String address, final RemotingCommand request) {
        final Channel channel = this.clientChannelManager.createIfAbsent(address);
        if (channel != null && channel.isActive()) {
            this.invokeOnewayWithInterceptor(channel, request);
        } else {
            this.clientChannelManager.closeChannel(address, channel);
        }
    }