com.highqsoft.avalon.distributor

Class SessionManager

java.lang.Object

com.highqsoft.avalon.distributor.SessionManager

public class SessionManager
extends java.lang.Object

The class manages the the sessions of the registered Avalon workers and the redundant Avalon Distributor.

Constructor Summary

Constructors

Constructor and Description
SessionManager(CorbaManager corbaManager)

Method Summary

Methods

Modifier and Type	Method and Description
java.lang.String	addAvalonWoker(AoFactory aoFactory, java.lang.String hostname) Add an new Avalon Worker to the internal session list
java.lang.String	addAvalonWoker(AoFactory aoFactory, java.lang.String hostname, java.lang.String workerName) Add an new Avalon Worker to the internal session list with the given worker name
void	addSession(java.lang.String workerId, int id) New AoSession was created from factory
AoFactory	getNextAoFactory() Return the next avalon worker factory for creating new session
int	getNextSessionId(java.lang.String workerId) Returns the next session id
com.highqsoft.avalon.distributor.SessionManager.AvalonWorkerInfo	getNextWorker() Get the next worker to create a session
void	initialize() Initialize the session informations
void	notifySessionClosed(java.lang.String workerId, int sessionId) This is called, when the session is closed, to remove the session from the list.
void	removeAvalonWorker(java.lang.String workerId) Removes a avalon worker from the list, when worker is no longr available
int	setNextSessionId(int distributorSessionId) Called from redundant distributor for synchronizing session id.
int	setNextWorkerId(int distributorWorkerId) Is called from redundant distributor to the the next worker id
void	showJavaMemory() Show the used java memory.
void	stopObserverThread()
com.highqsoft.avalon.T_Distributor_Data	synchronizeDistributorData(com.highqsoft.avalon.T_Distributor_Data distributorData) Synchronizes the worker and session informations with the delivered information from redundant avalon distributor.

Methods inherited from class java.lang.Object

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

Constructor Detail

SessionManager

public SessionManager(CorbaManager corbaManager)

Method Detail

addAvalonWoker

public java.lang.String addAvalonWoker(AoFactory aoFactory,
                              java.lang.String hostname)

Add an new Avalon Worker to the internal session list

addAvalonWoker

public java.lang.String addAvalonWoker(AoFactory aoFactory,
                              java.lang.String hostname,
                              java.lang.String workerName)
                                throws com.highqsoft.avalon.AvalonException

Add an new Avalon Worker to the internal session list with the given worker name

Throws:

com.highqsoft.avalon.AvalonException

setNextWorkerId

public int setNextWorkerId(int distributorWorkerId)

Is called from redundant distributor to the the next worker id

getNextSessionId

public int getNextSessionId(java.lang.String workerId)
                     throws com.highqsoft.avalon.AvalonException

Returns the next session id

Throws:

com.highqsoft.avalon.AvalonException

setNextSessionId

public int setNextSessionId(int distributorSessionId)

Called from redundant distributor for synchronizing session id.

getNextAoFactory

public AoFactory getNextAoFactory()
                           throws com.highqsoft.avalon.AvalonException

Return the next avalon worker factory for creating new session

Throws:

com.highqsoft.avalon.AvalonException

getNextWorker

public com.highqsoft.avalon.distributor.SessionManager.AvalonWorkerInfo getNextWorker()
                                                                               throws com.highqsoft.avalon.AvalonException

Get the next worker to create a session

Returns:

the worker

Throws:

com.highqsoft.avalon.AvalonException - in case no worker is found.

notifySessionClosed

public void notifySessionClosed(java.lang.String workerId,
                       int sessionId)

This is called, when the session is closed, to remove the session from the list.

removeAvalonWorker

public void removeAvalonWorker(java.lang.String workerId)
                        throws com.highqsoft.avalon.AvalonException

Removes a avalon worker from the list, when worker is no longr available

Throws:

com.highqsoft.avalon.AvalonException

addSession

public void addSession(java.lang.String workerId,
              int id)

New AoSession was created from factory

stopObserverThread

public void stopObserverThread()

synchronizeDistributorData

public com.highqsoft.avalon.T_Distributor_Data synchronizeDistributorData(com.highqsoft.avalon.T_Distributor_Data distributorData)
                                                                   throws com.highqsoft.avalon.AvalonException

Synchronizes the worker and session informations with the delivered information from redundant avalon distributor.

Throws:

com.highqsoft.avalon.AvalonException

initialize

public void initialize()

Initialize the session informations

showJavaMemory

public void showJavaMemory()

Show the used java memory.