com.goldencode.p2j.net

Class VirtualSession

java.lang.Object

com.goldencode.p2j.net.BaseSession

com.goldencode.p2j.net.VirtualSession

All Implemented Interfaces:

LowLevelSession, MessageTypes, Session

Direct Known Subclasses:

RequesterSession

class VirtualSession
extends BaseSession

A concrete implementation of the Session interface, built upon BaseSession. This implementation is to be used for virtual, multiplexed connections between network nodes.

This class implements the superclass' abstract preprocess(Message) to set the session's context ID as the message's routing key's context ID. This is necessary to support the multiplexing of virtual sessions across a single transport queue.

Field Summary

Fields

Modifier and Type	Field and Description
private int	localContextID The context ID to which this virtual session is registered locally on this side of the connection.

Fields inherited from class com.goldencode.p2j.net.BaseSession

LOG

Fields inherited from interface com.goldencode.p2j.net.MessageTypes

ADDRESS_REPLY, ADDRESS_REQUEST, BEGIN_REPLY, ECHO, ECHO_REPLY, END_REPLY, INIT_CONVERSATION, INIT_REPLY, INIT_ROUTER, INIT_STANDARD, REPLY_ASYNC, REPLY_EXCEPTION_ASYNC, REPLY_EXCEPTION_SYNC, REPLY_SYNC, REQUEST_ASYNCH, REQUEST_SYNCH, UNKNOWN

Constructor Summary

Constructors

Constructor and Description
VirtualSession(Queue queue, java.lang.Object context, int peerID, int contextID) Constructor.

Method Summary

Modifier and Type	Method and Description
(package private) int	getLocalContextID() Get the context ID to which the virtual session is registered on this side.
protected void	preprocess(Message message) Update the security context ID of the given message to this session's (peer) context ID, before it is sent.
void	registerSynchronizer(StateSynchronizer sync) Overrides the parent class' implementation to disallow the registraction of a state synchronizer.

Methods inherited from class com.goldencode.p2j.net.BaseSession

addSessionListener, addSessionListener, cleanupContext, echo, echoReply, end, forward, getContext, getContextID, getException, getNodeAddress, getQueue, getRemoteAddress, isRunning, removeSessionListener, sendInitializationEvent, sendTerminationEvent, setContext, terminate, transact

Methods inherited from class java.lang.Object

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

Field Detail

localContextID

private int localContextID

The context ID to which this virtual session is registered locally on this side of the connection.

Constructor Detail

VirtualSession

VirtualSession(Queue queue,
               java.lang.Object context,
               int peerID,
               int contextID)

Constructor.

Parameters:

queue - Message transport.

context - Security context. Must not be null.

peerID - Unique identifier for this session's peer security context on the other side of the network connection.

contextID - Unique identifier for this session's local security context on the this side of the network connection.

Method Detail

registerSynchronizer

public void registerSynchronizer(StateSynchronizer sync)

Overrides the parent class' implementation to disallow the registraction of a state synchronizer. This is necessary because a virtual session is multiplexed and a state synchronizer currently supports only a one to one connection.

Specified by:

registerSynchronizer in interface Session

Overrides:

registerSynchronizer in class BaseSession

Parameters:

sync - The synchronizer to register or null if the currently registered synchronizer should be deregistered.

Throws:

java.lang.UnsupportedOperationException - always.

getLocalContextID

int getLocalContextID()

Get the context ID to which the virtual session is registered on this side.

Returns:

the context ID to which the virtual session is registered on this side.

preprocess

protected void preprocess(Message message)

Update the security context ID of the given message to this session's (peer) context ID, before it is sent. This will the other side of the connection to demultiplex the inbound message to provide the appropriate security context.

Specified by:

preprocess in class BaseSession

Parameters:

message - Message to process.