kaos.aci.flexfeed
Class ObserverManagerWithFlexfeed

java.lang.Object
  kaos.core.csi.observe.ObserverManagerImpl
      kaos.aci.flexfeed.ObserverManagerWithFlexfeed

All Implemented Interfaces:

ObserverManager

public class ObserverManagerWithFlexfeed
extends ObserverManagerImpl

Nested Class Summary

Nested classes/interfaces inherited from class kaos.core.csi.observe.ObserverManagerImpl

ObserverManagerImpl.MyRemoteKAoSObserver

Field Summary

protected static ObserverManager	__INSTANCE
protected java.util.HashMap	ObservableMap

Fields inherited from class kaos.core.csi.observe.ObserverManagerImpl

__INITIALIZED, _DEREGISTER_OBSERVER, _myLocator, _nickname, _NICKNAME_ROOT, _observablesDescriptions, _observers, _query, _REGISTER_OBSERVER, _transport, _transportName

Constructor Summary

ObserverManagerWithFlexfeed()

Method Summary

void	deregisterObserver(KAoSObserver observer, java.lang.String updateType, java.io.Serializable updateCondition, java.lang.String observableGUID) Deregister the given KAoSObserver from the registry of observers asoociated with the KAoSObservable, whose GUID is given.
static ObserverManager	getInstance(java.lang.String transportName) Retrieve an instance of ObserverManagerObserverManagerWithFlexFeed.
static ObserverManager	getInstance(java.lang.String transportName, java.lang.String nickName) Retrieve a reference to the ObserverManager.
void	registerObserver(KAoSObserver observer, java.lang.String updateType, java.io.Serializable updateCondition, java.lang.String observableGUID) Register the given KAoSObserver with the KAoSObservable, whose GUID is given for updates described by the updateType and updateConditions.

Methods inherited from class kaos.core.csi.observe.ObserverManagerImpl

assertNotLocatable, deregisterObserver, equals, getID, hashCode, initialize, main, printDebugString, receiveMessage, registerKAoSExtensionComponentObserver, registerObserver, registerObserver, satisfyRequest, updateObserver

Methods inherited from class java.lang.Object

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

Field Detail

__INSTANCE

protected static final ObserverManager __INSTANCE

ObservableMap

protected java.util.HashMap ObservableMap

Constructor Detail

ObserverManagerWithFlexfeed

public ObserverManagerWithFlexfeed()

Method Detail

getInstance

public static ObserverManager getInstance(java.lang.String transportName)
                                   throws java.lang.Exception

Retrieve an instance of ObserverManagerObserverManagerWithFlexFeed.

Returns:

a singleton, ObserverManagerObserverManagerWithFlexFeed.

Throws:

java.lang.Exception

getInstance

public static ObserverManager getInstance(java.lang.String transportName,
                                          java.lang.String nickName)
                                   throws java.lang.Exception

Retrieve a reference to the ObserverManager.

Parameters:

transportName - is a String containing the name of the transport to use by the ObserverManager.

nickName - is a String containing the nick name of the ObserverManager that may be used by certain transport implementations, or null if not required by the transport.

Returns:

a reference to the ObserverManager

Throws:

java.lang.Exception

registerObserver

public void registerObserver(KAoSObserver observer,
                             java.lang.String updateType,
                             java.io.Serializable updateCondition,
                             java.lang.String observableGUID)
                      throws NotLocatableException,
                             TransportFailure

Register the given KAoSObserver with the KAoSObservable, whose GUID is given for updates described by the updateType and updateConditions.

Specified by:

registerObserver in interface ObserverManager

Overrides:

registerObserver in class ObserverManagerImpl

Parameters:

observer - KAoSObserver requesting registration for updates.

updateType - String indicating type of update the KAoSObserver is interested in.

updateCondition - Serializable describing the conditions under which to send the update.

observableGUID - String containing the GUID of the KAoSObservable to register with.

Throws:

NotLocatableException - when the KAoSObservable cannot be located.

TransportFailure - when transport services fails.

deregisterObserver

public void deregisterObserver(KAoSObserver observer,
                               java.lang.String updateType,
                               java.io.Serializable updateCondition,
                               java.lang.String observableGUID)
                        throws NotLocatableException,
                               TransportFailure

Description copied from class: ObserverManagerImpl

Deregister the given KAoSObserver from the registry of observers asoociated with the KAoSObservable, whose GUID is given.

Specified by:

deregisterObserver in interface ObserverManager

Overrides:

deregisterObserver in class ObserverManagerImpl

Parameters:

observer - KAoSObserver deregistering.

updateType - String indicating type of update the KAoSObserver is no longer interested in.

updateCondition - Serializable containing the condition the KAoSObserver is no longer interested in.

observableGUID - String specifying the GUID of the observable, from which to deregister for the given update type.

Throws:

NotLocatableException - when the KAoSObservable cannot be located.

TransportFailure - when transport services fail.