net.metanotion.rpc
Class IoSessionMessageSocket

java.lang.Object
  net.metanotion.rpc.IoSessionMessageSocket

All Implemented Interfaces:

java.io.Closeable, MessageSocket, Unknown

public final class IoSessionMessageSocket
extends java.lang.Object
implements MessageSocket

Constructor Summary

IoSessionMessageSocket(java.util.concurrent.ExecutorService pool, IoSession session, java.util.List<java.lang.String> protocols)

Method Summary

void	close()
<I> I	getInterface(java.lang.Class<I> theInterface) Return a proxy/representation of this object that is compatible with the requested interface.
void	onClose(java.lang.Runnable event)
void	operationComplete(IoFuture future)

Methods inherited from class java.lang.Object

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

Constructor Detail

IoSessionMessageSocket

public IoSessionMessageSocket(java.util.concurrent.ExecutorService pool,
                              IoSession session,
                              java.util.List<java.lang.String> protocols)
                       throws java.lang.ClassNotFoundException

Throws:

java.lang.ClassNotFoundException

Method Detail

getInterface

public <I> I getInterface(java.lang.Class<I> theInterface)

Description copied from interface: Unknown

Return a proxy/representation of this object that is compatible with the requested interface.

Specified by:

getInterface in interface Unknown

Parameters:

theInterface - Java class object representing the interface you would like.

Returns:

an object which is an instance of the interface requested.

close

public void close()
           throws java.io.IOException

Specified by:

close in interface java.io.Closeable

Throws:

java.io.IOException

onClose

public void onClose(java.lang.Runnable event)

Specified by:

onClose in interface MessageSocket

operationComplete

public void operationComplete(IoFuture future)