|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||
java.lang.Objectorg.apache.mina.common.IoHandlerAdapter
org.apache.mina.handler.StreamIoHandler
public abstract class StreamIoHandler
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 | |
|---|---|
protected |
StreamIoHandler()
|
| Method Summary | |
|---|---|
void |
exceptionCaught(IoSession session,
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,
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 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. |
| Methods inherited from class org.apache.mina.common.IoHandlerAdapter |
|---|
messageSent, sessionCreated |
| Methods inherited from class java.lang.Object |
|---|
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
| Constructor Detail |
|---|
protected StreamIoHandler()
| Method Detail |
|---|
protected abstract void processStreamIo(IoSession session,
InputStream in,
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 IoHandlersessionOpened in class IoHandlerAdapter
public void sessionClosed(IoSession session)
throws Exception
sessionClosed in interface IoHandlersessionClosed in class IoHandlerAdapterException
public void messageReceived(IoSession session,
Object buf)
messageReceived in interface IoHandlermessageReceived in class IoHandlerAdapter
public void exceptionCaught(IoSession session,
Throwable cause)
exceptionCaught in interface IoHandlerexceptionCaught in class IoHandlerAdapter
public void sessionIdle(IoSession session,
IdleStatus status)
sessionIdle in interface IoHandlersessionIdle in class IoHandlerAdapter
|
||||||||||
| PREV CLASS NEXT CLASS | FRAMES NO FRAMES | |||||||||
| SUMMARY: NESTED | FIELD | CONSTR | METHOD | DETAIL: FIELD | CONSTR | METHOD | |||||||||