public void userEventTriggered()

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

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

        public void userEventTriggered(ChannelHandlerContext ctx, Object evt) {
            if (evt instanceof IdleStateEvent) {
                IdleStateEvent event = (IdleStateEvent) evt;
                if (event.state().equals(IdleState.ALL_IDLE)) {
                    LOG.info("Close channel {} because of idle event {} ", ctx.channel(), event);
                    NettyRemotingClient.this.clientChannelManager.closeChannel(ctx.channel());
                    putNettyEvent(new NettyChannelEvent(NettyChannelEventType.IDLE, ctx.channel()));
                }
            }

            ctx.fireUserEventTriggered(evt);
        }