com.viaoa.remote.multiplexer

Class OARemoteMultiplexerServer.Session

java.lang.Object

com.viaoa.remote.multiplexer.OARemoteMultiplexerServer.Session

Enclosing class:

OARemoteMultiplexerServer

public class OARemoteMultiplexerServer.Session
extends Object

Tracks each client connection.

Author:

vvia

See Also:

to have this session removed from collection.

Field Summary

Fields

Modifier and Type	Field and Description
int	connectionId
Socket	realSocket

Constructor Summary

Constructors

Constructor and Description
Session()

Method Summary

Modifier and Type	Method and Description
protected void	_writeOnQueueSocketX(RequestInfo ri)
void	addSocketForStoC(VirtualSocket socket)
BindInfo	createBindInfo(BindInfo biParent, String name, Object obj, Class interfaceClass)
protected BindInfo	getBindInfo(Object obj)
protected BindInfo	getBindInfo(String name)
ConcurrentHashMap<Integer,Boolean>	getGuidHashMap()
VirtualSocket	getSocketForStoC() used by server when calling methods on a remote object that was created on the client, so that the server can call any of the methods on it.
void	releaseSocketForStoC(VirtualSocket socket)
protected BindInfo	removeBindInfo(String name)
void	setupAsyncQueueSender(String asyncQueueName)
void	writeOnQueueSocket(RequestInfo ri)

Methods inherited from class java.lang.Object

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

Field Detail

connectionId

public int connectionId

realSocket

public Socket realSocket

Constructor Detail

Session

public Session()

Method Detail

getGuidHashMap

public ConcurrentHashMap<Integer,Boolean> getGuidHashMap()

getBindInfo

protected BindInfo getBindInfo(String name)

removeBindInfo

protected BindInfo removeBindInfo(String name)

getBindInfo

protected BindInfo getBindInfo(Object obj)

getSocketForStoC

public VirtualSocket getSocketForStoC()
                               throws Exception

used by server when calling methods on a remote object that was created on the client, so that the server can call any of the methods on it.

Throws:

Exception

releaseSocketForStoC

public void releaseSocketForStoC(VirtualSocket socket)
                          throws Exception

Throws:

Exception

addSocketForStoC

public void addSocketForStoC(VirtualSocket socket)

createBindInfo

public BindInfo createBindInfo(BindInfo biParent,
                               String name,
                               Object obj,
                               Class interfaceClass)

writeOnQueueSocket

public void writeOnQueueSocket(RequestInfo ri)
                        throws Exception

Throws:

Exception

_writeOnQueueSocketX

protected void _writeOnQueueSocketX(RequestInfo ri)
                             throws Exception

Throws:

Exception

setupAsyncQueueSender

public void setupAsyncQueueSender(String asyncQueueName)