com.highqsoft.avalon.distributor

Class DistributorFactory

java.lang.Object

org.omg.PortableServer.Servant

com.highqsoft.avalon.AvalonDistributorFactoryPOA

com.highqsoft.avalon.distributor.DistributorFactory

All Implemented Interfaces:

com.highqsoft.avalon.AvalonDistributorFactory, com.highqsoft.avalon.AvalonDistributorFactoryOperations, java.io.Serializable, org.omg.CORBA.Object, org.omg.CORBA.portable.IDLEntity, org.omg.CORBA.portable.InvokeHandler

public class DistributorFactory
extends com.highqsoft.avalon.AvalonDistributorFactoryPOA
implements com.highqsoft.avalon.AvalonDistributorFactory

The class manage the communications between avalon distributor and the avalon worker. Also the information transfer between two avalon distributors is done by this class.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
DistributorFactory(SessionManager sessionManager, EventManager eventManager)

Method Summary

Methods

Modifier and Type	Method and Description
org.omg.CORBA.Request	_create_request(org.omg.CORBA.Context ctx, java.lang.String operation, org.omg.CORBA.NVList arg_list, org.omg.CORBA.NamedValue result)
org.omg.CORBA.Request	_create_request(org.omg.CORBA.Context ctx, java.lang.String operation, org.omg.CORBA.NVList arg_list, org.omg.CORBA.NamedValue result, org.omg.CORBA.ExceptionList exclist, org.omg.CORBA.ContextList ctxlist)
org.omg.CORBA.Object	_duplicate()
org.omg.CORBA.DomainManager[]	_get_domain_managers()
org.omg.CORBA.Policy	_get_policy(int policy_type)
int	_hash(int maximum)
boolean	_is_equivalent(org.omg.CORBA.Object other)
void	_release()
org.omg.CORBA.Request	_request(java.lang.String operation)
org.omg.CORBA.Object	_set_policy_override(org.omg.CORBA.Policy[] policies, org.omg.CORBA.SetOverrideType set_add)
void	deRegisterAvalonWorker(java.lang.String workerId) Is called from Avalon worker for deregistration, when it shut down
T_LONGLONG	getCurrentTimeStamp() Is called from Avalon worker for checking Avalon Distributor is alive
int	getNextSessionId(java.lang.String workerId) Is called from Avalon worker to get the next session id
void	initializeDistributor()
void	newCorbaEvent(java.lang.String workerId, com.highqsoft.avalon.T_CorbaEvent event)
void	newSessionEvent(java.lang.String workerId, com.highqsoft.avalon.T_SessionEvent event)
void	notifySessionClosed(java.lang.String workerId, int sessionId) Is called from Avalon worker when a session is closed
java.lang.String	registerAvalonWorker(AoFactory aoFactory, java.lang.String hostname) Is called from Avalon worker for registering
java.lang.String	registerAvalonWorkerWithName(AoFactory aoFactory, java.lang.String hostname, java.lang.String workername)
int	setNextDistributorSessionId(int distributorSessionId)
int	setNextDistributorWorkerId(int distributorWorkerId)
com.highqsoft.avalon.T_Distributor_Data	synchronizeDistributorData(com.highqsoft.avalon.T_Distributor_Data distributorData) Is called from redundant Avalon Distributor for synchronizing session information

Methods inherited from class com.highqsoft.avalon.AvalonDistributorFactoryPOA

_all_interfaces, _invoke, _this, _this

Methods inherited from class org.omg.PortableServer.Servant

_default_POA, _get_delegate, _get_interface_def, _is_a, _non_existent, _object_id, _orb, _poa, _set_delegate, _this_object, _this_object

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.omg.CORBA.Object

_get_interface_def, _is_a, _non_existent

Constructor Detail

DistributorFactory

public DistributorFactory(SessionManager sessionManager,
                  EventManager eventManager)

Method Detail

registerAvalonWorker

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

Is called from Avalon worker for registering

Specified by:

registerAvalonWorker in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException

registerAvalonWorkerWithName

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

Specified by:

registerAvalonWorkerWithName in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException

deRegisterAvalonWorker

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

Is called from Avalon worker for deregistration, when it shut down

Specified by:

deRegisterAvalonWorker in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException

notifySessionClosed

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

Is called from Avalon worker when a session is closed

Specified by:

notifySessionClosed in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

newCorbaEvent

public void newCorbaEvent(java.lang.String workerId,
                 com.highqsoft.avalon.T_CorbaEvent event)
                   throws com.highqsoft.avalon.AvalonException

Specified by:

newCorbaEvent in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException

newSessionEvent

public void newSessionEvent(java.lang.String workerId,
                   com.highqsoft.avalon.T_SessionEvent event)
                     throws com.highqsoft.avalon.AvalonException

Specified by:

newSessionEvent in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException

getCurrentTimeStamp

public T_LONGLONG getCurrentTimeStamp()
                               throws com.highqsoft.avalon.AvalonException

Is called from Avalon worker for checking Avalon Distributor is alive

Specified by:

getCurrentTimeStamp in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException

getNextSessionId

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

Is called from Avalon worker to get the next session id

Specified by:

getNextSessionId in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException

synchronizeDistributorData

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

Is called from redundant Avalon Distributor for synchronizing session information

Specified by:

synchronizeDistributorData in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException

setNextDistributorSessionId

public int setNextDistributorSessionId(int distributorSessionId)
                                throws com.highqsoft.avalon.AvalonException

Specified by:

setNextDistributorSessionId in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException

setNextDistributorWorkerId

public int setNextDistributorWorkerId(int distributorWorkerId)
                               throws com.highqsoft.avalon.AvalonException

Specified by:

setNextDistributorWorkerId in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException

_is_equivalent

public boolean _is_equivalent(org.omg.CORBA.Object other)

Specified by:

_is_equivalent in interface org.omg.CORBA.Object

_hash

public int _hash(int maximum)

Specified by:

_hash in interface org.omg.CORBA.Object

_duplicate

public org.omg.CORBA.Object _duplicate()

Specified by:

_duplicate in interface org.omg.CORBA.Object

_release

public void _release()

Specified by:

_release in interface org.omg.CORBA.Object

_request

public org.omg.CORBA.Request _request(java.lang.String operation)

Specified by:

_request in interface org.omg.CORBA.Object

_create_request

public org.omg.CORBA.Request _create_request(org.omg.CORBA.Context ctx,
                                    java.lang.String operation,
                                    org.omg.CORBA.NVList arg_list,
                                    org.omg.CORBA.NamedValue result)

Specified by:

_create_request in interface org.omg.CORBA.Object

_create_request

public org.omg.CORBA.Request _create_request(org.omg.CORBA.Context ctx,
                                    java.lang.String operation,
                                    org.omg.CORBA.NVList arg_list,
                                    org.omg.CORBA.NamedValue result,
                                    org.omg.CORBA.ExceptionList exclist,
                                    org.omg.CORBA.ContextList ctxlist)

Specified by:

_create_request in interface org.omg.CORBA.Object

_get_policy

public org.omg.CORBA.Policy _get_policy(int policy_type)

Specified by:

_get_policy in interface org.omg.CORBA.Object

_get_domain_managers

public org.omg.CORBA.DomainManager[] _get_domain_managers()

Specified by:

_get_domain_managers in interface org.omg.CORBA.Object

_set_policy_override

public org.omg.CORBA.Object _set_policy_override(org.omg.CORBA.Policy[] policies,
                                        org.omg.CORBA.SetOverrideType set_add)

Specified by:

_set_policy_override in interface org.omg.CORBA.Object

initializeDistributor

public void initializeDistributor()
                           throws com.highqsoft.avalon.AvalonException

Specified by:

initializeDistributor in interface com.highqsoft.avalon.AvalonDistributorFactoryOperations

Throws:

com.highqsoft.avalon.AvalonException