@Test public void testAddConnection() throws Exception { decoder.addConnection("domain", mock(Connection.class)); verify(sxpNode).addConnection(any(Connection.class), anyString()); }
protected void addConnection(String domain, Connection connection) { owner.addConnection(connection, domain); }
ConnectionDecoder extends SimpleChannelInboundHandler<ByteBuf> { protected void addConnection(String domain, Connection connection) { owner.addConnection(connection, domain); } }
ConnectionDecoder extends SimpleChannelInboundHandler<ByteBuf> { protected void addConnection(String domain, Connection connection) { owner.addConnection(connection, domain); } ConnectionDecoder(SxpNode owner); }
ConnectionDecoder extends SimpleChannelInboundHandler<ByteBuf> { protected void addConnection(String domain, Connection connection) { owner.addConnection(connection, domain); } ConnectionDecoder(SxpNode owner); @Override void channelActive(ChannelHandlerContext ctx); @Override void channelRead0(ChannelHandlerContext ctx, ByteBuf message); }
ConnectionDecoder extends SimpleChannelInboundHandler<ByteBuf> { protected void addConnection(String domain, Connection connection) { owner.addConnection(connection, domain); } ConnectionDecoder(SxpNode owner); @Override void channelActive(ChannelHandlerContext ctx); @Override void channelRead0(ChannelHandlerContext ctx, ByteBuf message);  }