Package org.apache.mina.handler
Class StreamIoHandler
java.lang.Object
org.apache.mina.common.IoHandlerAdapter
org.apache.mina.handler.StreamIoHandler
- All Implemented Interfaces:
IoHandler
A
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.
-
Constructor Summary
Constructors -
Method Summary
Modifier and TypeMethodDescriptionvoid
exceptionCaught
(IoSession session, Throwable cause) Forwards caught exceptions to input stream.int
Returns read timeout in seconds.int
Returns write timeout in seconds.void
messageReceived
(IoSession session, Object buf) Forwards read data to input stream.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.void
sessionClosed
(IoSession session) Closes streamsvoid
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.Methods inherited from class org.apache.mina.common.IoHandlerAdapter
messageSent, sessionCreated
-
Constructor Details
-
StreamIoHandler
protected StreamIoHandler()
-
-
Method Details
-
processStreamIo
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
Initializes streams and timeout settings.- Specified by:
sessionOpened
in interfaceIoHandler
- Overrides:
sessionOpened
in classIoHandlerAdapter
-
sessionClosed
Closes streams- Specified by:
sessionClosed
in interfaceIoHandler
- Overrides:
sessionClosed
in classIoHandlerAdapter
- Throws:
Exception
-
messageReceived
Forwards read data to input stream.- Specified by:
messageReceived
in interfaceIoHandler
- Overrides:
messageReceived
in classIoHandlerAdapter
-
exceptionCaught
Forwards caught exceptions to input stream.- Specified by:
exceptionCaught
in interfaceIoHandler
- Overrides:
exceptionCaught
in classIoHandlerAdapter
-
sessionIdle
Handles read timeout.- Specified by:
sessionIdle
in interfaceIoHandler
- Overrides:
sessionIdle
in classIoHandlerAdapter
-