org.jactr.tools.async.common

Class BaseIOHandler

java.lang.Object

org.apache.mina.core.service.IoHandlerAdapter

org.apache.mina.handler.demux.DemuxingIoHandler

org.jactr.tools.async.common.BaseIOHandler

All Implemented Interfaces:

org.apache.mina.core.service.IoHandler

Direct Known Subclasses:

RemoteIOHandler, ShadowIOHandler

public class BaseIOHandler
extends org.apache.mina.handler.demux.DemuxingIoHandler

Author:

developer

Constructor Summary

Constructors

Constructor and Description
BaseIOHandler()

Method Summary

Modifier and Type	Method and Description
void	disconnect()
void	disconnect(boolean force) disconnect from everyone
ICredentials	getCredentials()
boolean	isConnected()
void	sessionClosed(org.apache.mina.core.session.IoSession session)
void	sessionOpened(org.apache.mina.core.session.IoSession session)
void	setCredentials(ICredentials credentials)
boolean	waitForConnection(long timeOut)
void	waitForDisconnect() wait until all the active connections have been closed
void	waitForPendingWrites()
org.apache.mina.core.future.WriteFuture	write(java.lang.Object message) all writes should be through here so that we can track the status of the writes

Methods inherited from class org.apache.mina.handler.demux.DemuxingIoHandler

addExceptionHandler, addReceivedMessageHandler, addSentMessageHandler, exceptionCaught, findExceptionHandler, findReceivedMessageHandler, findSentMessageHandler, getExceptionHandlerMap, getMessageHandler, getReceivedMessageHandlerMap, getSentMessageHandlerMap, messageReceived, messageSent, removeExceptionHandler, removeReceivedMessageHandler, removeSentMessageHandler

Methods inherited from class org.apache.mina.core.service.IoHandlerAdapter

sessionCreated, sessionIdle

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

BaseIOHandler

public BaseIOHandler()

Method Detail

setCredentials

public void setCredentials(ICredentials credentials)

sessionOpened

public void sessionOpened(org.apache.mina.core.session.IoSession session)
                   throws java.lang.Exception

Specified by:

sessionOpened in interface org.apache.mina.core.service.IoHandler

Overrides:

sessionOpened in class org.apache.mina.core.service.IoHandlerAdapter

Throws:

java.lang.Exception

sessionClosed

public void sessionClosed(org.apache.mina.core.session.IoSession session)
                   throws java.lang.Exception

Specified by:

sessionClosed in interface org.apache.mina.core.service.IoHandler

Overrides:

sessionClosed in class org.apache.mina.core.service.IoHandlerAdapter

Throws:

java.lang.Exception

isConnected

public boolean isConnected()

getCredentials

public ICredentials getCredentials()

waitForPendingWrites

public void waitForPendingWrites()
                          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException

write

public org.apache.mina.core.future.WriteFuture write(java.lang.Object message)

all writes should be through here so that we can track the status of the writes

Parameters:

message -

disconnect

public void disconnect()
                throws java.lang.Exception

Throws:

java.lang.Exception

disconnect

public void disconnect(boolean force)
                throws java.lang.Exception

disconnect from everyone

Throws:

java.lang.Exception

waitForDisconnect

public void waitForDisconnect()
                       throws java.lang.InterruptedException

wait until all the active connections have been closed

Throws:

java.lang.InterruptedException

waitForConnection

public boolean waitForConnection(long timeOut)
                          throws java.lang.InterruptedException

Throws:

java.lang.InterruptedException