public class ConnectionHandler implements IoHandler { private GameEngine engine; private PacketQueue packets; public ConnectionHandler(GameEngine engine) { this.engine = engine; packets = engine.getPacketQueue(); } public void exceptionCaught(IoSession session, Throwable cause) { System.out.println(cause); session.close(); } public void messageReceived(IoSession session, Object message) { Packet p = (Packet) message; packets.add(p); } public void messageSent(IoSession session, Object message) { /* Packet p = (Packet) message; System.out.println("Sent packet " + p.getID() + " with length" + p.getLength() + " and israw == " + p.isBare()); ( */ } public void sessionClosed(IoSession session) { System.out.println("Session Closed "+session.getRemoteAddress()); } public void sessionCreated(IoSession session) { session.getFilterChain().addFirst("protocolFilter", new ProtocolCodecFilter(new RS2CodecFactory())); System.out.println("Session Created "+session.getRemoteAddress()); } public void sessionIdle(IoSession session, IdleStatus status) { System.out.println("Session Idle now closing"+session.getRemoteAddress()); session.close(); } public void sessionOpened(IoSession session) { //session.setAttachment(new Player(session)); System.out.println("Session Opened "+session.getRemoteAddress()); session.setIdleTime(IdleStatus.BOTH_IDLE, 60); } }