com.goldencode.p2j.net

Class RequesterSession

java.lang.Object

com.goldencode.p2j.net.BaseSession

com.goldencode.p2j.net.VirtualSession

com.goldencode.p2j.net.RequesterSession

All Implemented Interfaces:

LowLevelSession, MessageTypes, Session

final class RequesterSession
extends VirtualSession

An extension of a multiplexed session, used on the requesting side of a virtualized connection.

This class overrides the parent's terminate() method to make a remote call to trigger cleanup of the virtual session on the other side of the network connection. It also overrides cleanupContext() to do nothing, to avoid terminating the current user context.

Field Summary

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
RequesterSession(Queue queue, java.lang.Object context, int peerID, int contextID) Constructor.

Method Summary

Modifier and Type	Method and Description
protected void	cleanupContext() Override the parent's implementation to do nothing.
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	terminate() Terminate the virtual network session on the remote side of the connection, then perform termination processing for the session on this side.

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

getLocalContextID, registerSynchronizer

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

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

Methods inherited from class java.lang.Object

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

Constructor Detail

RequesterSession

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

Constructor. The current thread's effective context will be used as the session's security context.

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

terminate

public void terminate()

Terminate the virtual network session on the remote side of the connection, then perform termination processing for the session on this side.

Specified by:

terminate in interface Session

Overrides:

terminate in class BaseSession

cleanupContext

protected final void cleanupContext()

Override the parent's implementation to do nothing. The security context must not be terminated by this session, because it was not created for this session. Rather, the session was "piggy-backed" on the existing security context for the authenticated subject which requested the virtual session.

Overrides:

cleanupContext in class BaseSession

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.

Overrides:

preprocess in class VirtualSession

Parameters:

message - Message to process.