Class StreamIoHandler

Method Details

• processStreamIo

  protected abstract void processStreamIo(IoSession session, InputStream in, OutputStream out)

  Implement this method to execute your stream I/O logic; please note that you must forward the process request to other thread or thread pool.

• getReadTimeout

  public int getReadTimeout()

  Returns read timeout in seconds. The default value is 0 (disabled).

• setReadTimeout

  public void setReadTimeout(int readTimeout)

  Sets read timeout in seconds. The default value is 0 (disabled).

• getWriteTimeout

  public int getWriteTimeout()

  Returns write timeout in seconds. The default value is 0 (disabled).

• setWriteTimeout

  public void setWriteTimeout(int writeTimeout)

  Sets write timeout in seconds. The default value is 0 (disabled).

• sessionOpened

  public void sessionOpened(IoSession session)

  Initializes streams and timeout settings.

  Specified by:

  sessionOpened in interface IoHandler

  Overrides:

  sessionOpened in class IoHandlerAdapter

• sessionClosed

  public void sessionClosed(IoSession session) throws Exception

  Closes streams

  Specified by:

  sessionClosed in interface IoHandler

  Overrides:

  sessionClosed in class IoHandlerAdapter

  Throws:

  Exception

• messageReceived

  public void messageReceived(IoSession session, Object buf)

  Forwards read data to input stream.

  Specified by:

  messageReceived in interface IoHandler

  Overrides:

  messageReceived in class IoHandlerAdapter

• exceptionCaught

  public void exceptionCaught(IoSession session, Throwable cause)

  Forwards caught exceptions to input stream.

  Specified by:

  exceptionCaught in interface IoHandler

  Overrides:

  exceptionCaught in class IoHandlerAdapter

• sessionIdle

  public void sessionIdle(IoSession session, IdleStatus status)

  Handles read timeout.

  Specified by:

  sessionIdle in interface IoHandler

  Overrides:

  sessionIdle in class IoHandlerAdapter