public void stop()

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

12 lines of code
2 McCabe index (conditional complexity)


    public void stop() {
        try {
            clientChannelManager.clear();

            this.ioGroup.shutdownGracefully(clientConfig.getRemotingShutdownQuietPeriodMillis(),
                clientConfig.getRemotingShutdownTimeoutMillis(), TimeUnit.MILLISECONDS).sync();

            this.workerGroup.shutdownGracefully(clientConfig.getRemotingShutdownQuietPeriodMillis(),
                clientConfig.getRemotingShutdownTimeoutMillis(), TimeUnit.MILLISECONDS).sync();
        } catch (Exception e) {
            LOG.warn("RemotingClient stopped error !", e);
        }

        super.stop();
    }