fulmine.model.container.subscription.remote
Class RemoteContainerSubscriptionManager

java.lang.Object
  fulmine.AbstractLifeCycle
      fulmine.event.subscription.SubscriptionManager
          fulmine.model.container.subscription.ContainerSubscriptionManager
              fulmine.model.container.subscription.remote.RemoteContainerSubscriptionManager

All Implemented Interfaces:

ISubscriptionManager, IDestroyable, ILifeCycle

public class RemoteContainerSubscriptionManager
extends ContainerSubscriptionManager

Adds support for handling subscriptions for remote containers.

Author:

Ramon Servadei

Field Summary

Fields inherited from class fulmine.model.container.subscription.ContainerSubscriptionManager

eventHandler

Constructor Summary

RemoteContainerSubscriptionManager(IFrameworkContext context, String remoteContextIdentity, ISubscriptionFactory factory)
Standard constructor

Method Summary

protected boolean	doEventSourceExists(IAddressable id) Template method to identify if the IEventSource identified by the IAddressable argument exists.
protected IContainer	doGetEventSource(IAddressable id) Template method to get the IEventSource identified by the IAddressable argument.
protected Collection<IContainer>	doGetEventSources() Template method to get the collection of IEventSource instances the manager will operate over.
protected void	doRaiseSubscribeEvent(ISubscriptionParameters parameters)
protected void	doRaiseUnsubscribeEvent(ISubscriptionParameters parameters)
protected AsyncLog	getLog() Get the log to use for the object hierarchy

Methods inherited from class fulmine.model.container.subscription.ContainerSubscriptionManager

doAddListener, doDestroy, doEventSourceCreated, doStart

Methods inherited from class fulmine.event.subscription.SubscriptionManager

addListener, eventSourceCreated, eventSourceDestroyed, getContext, getListeners, getSubscribedSources, getSubscribedSources, getSubscription, getSubscriptions, includes, isSubscribed, removeListener, subscribe, toString, unsubscribe

Methods inherited from class fulmine.AbstractLifeCycle

checkActive, destroy, finalize, isActive, start

Methods inherited from class java.lang.Object

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

Methods inherited from interface fulmine.ILifeCycle

isActive, start

Methods inherited from interface fulmine.IDestroyable

destroy

Constructor Detail

RemoteContainerSubscriptionManager

public RemoteContainerSubscriptionManager(IFrameworkContext context,
                                          String remoteContextIdentity,
                                          ISubscriptionFactory factory)

Standard constructor

Parameters:

context - the context for this

remoteContextIdentity - the identity of the remote context for the subscriptions that this manager handles

factory - the container subscription factory to use

Method Detail

getLog

protected AsyncLog getLog()

Description copied from class: AbstractLifeCycle

Get the log to use for the object hierarchy

Overrides:

getLog in class ContainerSubscriptionManager

Returns:

the log to use for the object hierarchy

doGetEventSource

protected IContainer doGetEventSource(IAddressable id)

Description copied from class: ContainerSubscriptionManager

Template method to get the IEventSource identified by the IAddressable argument.

Overrides:

doGetEventSource in class ContainerSubscriptionManager

Parameters:

id - identifies the event source

Returns:

the IEventSource implementation to use

doGetEventSources

protected Collection<IContainer> doGetEventSources()

Description copied from class: SubscriptionManager

Template method to get the collection of IEventSource instances the manager will operate over.

Overrides:

doGetEventSources in class ContainerSubscriptionManager

Returns:

a collection of IEventSource instances

doEventSourceExists

protected boolean doEventSourceExists(IAddressable id)

Description copied from class: ContainerSubscriptionManager

Template method to identify if the IEventSource identified by the IAddressable argument exists.

Overrides:

doEventSourceExists in class ContainerSubscriptionManager

Parameters:

id - identifies the event source

Returns:

true if the container exists in the current context scope

doRaiseSubscribeEvent

protected void doRaiseSubscribeEvent(ISubscriptionParameters parameters)

Overrides:

doRaiseSubscribeEvent in class SubscriptionManager

doRaiseUnsubscribeEvent

protected void doRaiseUnsubscribeEvent(ISubscriptionParameters parameters)

Overrides:

doRaiseUnsubscribeEvent in class SubscriptionManager