Socks5AcceptorHandler extends IoHandlerAdapter { public void sessionOpened(IoSession session) throws Exception { log.info("SOCKS5 session opened"); session.setAttribute(STATE_KEY, ProxyState.OPENED); } Socks5AcceptorHandler(Socks5ConnectionsRegistry connections); void sessionOpened(IoSession session); void sessionIdle(IoSession session, IdleStatus status); void messageReceived(final IoSession session, Object message); void sessionClosed(IoSession session); void exceptionCaught(IoSession session, Throwable cause); static final AttributeKey STATE_KEY; static final AttributeKey PAIR_KEY; }
@Test public void sessionOpened() throws Exception { handler.sessionOpened(session); verify(session).setAttribute(Socks5AcceptorHandler.STATE_KEY, ProxyState.OPENED); }