@Test public void testChannelInactive() throws Exception { decoder.channelInactive(channelHandlerContext); verify(connection).setStateOff(eq(channelHandlerContext)); when(sxpNode.getConnection(any(SocketAddress.class))).thenReturn(null); decoder.channelInactive(channelHandlerContext); verify(connection).setStateOff(eq(channelHandlerContext)); }
@Override public void channelInactive(ChannelHandlerContext ctx) { LOG.warn(getLogMessage(owner, ctx, "Channel inactivation")); final SxpConnection connection = owner.getConnection(ctx.channel().remoteAddress()); if (connection == null) { return; } connection.getContext().executeChannelInactivationStrategy(ctx, connection); }
MessageDecoder extends SimpleChannelInboundHandler<ByteBuf> { @Override public void channelInactive(ChannelHandlerContext ctx) { LOG.warn(getLogMessage(owner, ctx, "Channel inactivation")); final SxpConnection connection = owner.getConnection(ctx.channel().remoteAddress()); if (connection == null) { return; } connection.getContext().executeChannelInactivationStrategy(ctx, connection); } }
MessageDecoder extends SimpleChannelInboundHandler<ByteBuf> { @Override public void channelInactive(ChannelHandlerContext ctx) { LOG.warn(getLogMessage(owner, ctx, "Channel inactivation")); final SxpConnection connection = owner.getConnection(ctx.channel().remoteAddress()); if (connection == null) { return; } connection.getContext().executeChannelInactivationStrategy(ctx, connection); } private  MessageDecoder(SxpNode owner, Profile profile); }
MessageDecoder extends SimpleChannelInboundHandler<ByteBuf> { @Override public void channelInactive(ChannelHandlerContext ctx) { LOG.warn(getLogMessage(owner, ctx, "Channel inactivation")); final SxpConnection connection = owner.getConnection(ctx.channel().remoteAddress()); if (connection == null) { return; } connection.getContext().executeChannelInactivationStrategy(ctx, connection); } private  MessageDecoder(SxpNode owner, Profile profile); static ChannelInboundHandler createClientProfile(SxpNode owner); static ChannelInboundHandler createServerProfile(SxpNode owner); static void sendErrorMessage(ChannelHandlerContext ctx, ErrorMessageException messageValidationException,
            SxpConnection connection); @Override void channelActive(ChannelHandlerContext ctx); @Override void channelInactive(ChannelHandlerContext ctx); @Override void channelRead0(ChannelHandlerContext ctx, ByteBuf message); @Override void channelReadComplete(ChannelHandlerContext ctx); @Override void exceptionCaught(ChannelHandlerContext ctx, Throwable cause); }
MessageDecoder extends SimpleChannelInboundHandler<ByteBuf> { @Override public void channelInactive(ChannelHandlerContext ctx) { LOG.warn(getLogMessage(owner, ctx, "Channel inactivation")); final SxpConnection connection = owner.getConnection(ctx.channel().remoteAddress()); if (connection == null) { return; } connection.getContext().executeChannelInactivationStrategy(ctx, connection); } private  MessageDecoder(SxpNode owner, Profile profile); static ChannelInboundHandler createClientProfile(SxpNode owner); static ChannelInboundHandler createServerProfile(SxpNode owner); static void sendErrorMessage(ChannelHandlerContext ctx, ErrorMessageException messageValidationException,
            SxpConnection connection); @Override void channelActive(ChannelHandlerContext ctx); @Override void channelInactive(ChannelHandlerContext ctx); @Override void channelRead0(ChannelHandlerContext ctx, ByteBuf message); @Override void channelReadComplete(ChannelHandlerContext ctx); @Override void exceptionCaught(ChannelHandlerContext ctx, Throwable cause);  }