public abstract class StreamIoHandler extends IoHandlerAdapter
IoHandler
that adapts asynchronous MINA events to stream I/O.
Please extend this class and implement
processStreamIo(IoSession, InputStream, OutputStream)
to
execute your stream I/O logic; please note that you must forward
the process request to other thread or thread pool.
Modifier | Constructor and Description |
---|---|
protected |
StreamIoHandler() |
Modifier and Type | Method and Description |
---|---|
void |
exceptionCaught(IoSession session,
java.lang.Throwable cause)
Forwards caught exceptions to input stream.
|
int |
getReadTimeout()
Returns read timeout in seconds.
|
int |
getWriteTimeout()
Returns write timeout in seconds.
|
void |
messageReceived(IoSession session,
java.lang.Object buf)
Forwards read data to input stream.
|
protected abstract void |
processStreamIo(IoSession session,
java.io.InputStream in,
java.io.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.
|
void |
sessionClosed(IoSession session)
Closes streams
|
void |
sessionIdle(IoSession session,
IdleStatus status)
Handles read timeout.
|
void |
sessionOpened(IoSession session)
Initializes streams and timeout settings.
|
void |
setReadTimeout(int readTimeout)
Sets read timeout in seconds.
|
void |
setWriteTimeout(int writeTimeout)
Sets write timeout in seconds.
|
messageSent, sessionCreated
protected abstract void processStreamIo(IoSession session, java.io.InputStream in, java.io.OutputStream out)
public int getReadTimeout()
public void setReadTimeout(int readTimeout)
public int getWriteTimeout()
public void setWriteTimeout(int writeTimeout)
public void sessionOpened(IoSession session)
sessionOpened
in interface IoHandler
sessionOpened
in class IoHandlerAdapter
public void sessionClosed(IoSession session) throws java.lang.Exception
sessionClosed
in interface IoHandler
sessionClosed
in class IoHandlerAdapter
java.lang.Exception
public void messageReceived(IoSession session, java.lang.Object buf)
messageReceived
in interface IoHandler
messageReceived
in class IoHandlerAdapter
public void exceptionCaught(IoSession session, java.lang.Throwable cause)
exceptionCaught
in interface IoHandler
exceptionCaught
in class IoHandlerAdapter
public void sessionIdle(IoSession session, IdleStatus status)
sessionIdle
in interface IoHandler
sessionIdle
in class IoHandlerAdapter
Copyright © 2004-2019 Apache MINA Project. All Rights Reserved.