org.overlord.bam.epn.embedded
Class EmbeddedEPNManager

java.lang.Object
  org.overlord.bam.epn.AbstractEPNManager
      org.overlord.bam.epn.embedded.EmbeddedEPNManager

All Implemented Interfaces:

EPNManager

public class EmbeddedEPNManager
extends AbstractEPNManager

This class provides the embedded implementation of the EPN Manager.

Nested Class Summary

protected class	EmbeddedEPNManager.EmbeddedChannel This is the embedded implementation of the Channel interface.
protected class	EmbeddedEPNManager.EmbeddedEPNContainer The embedded implementation of the EPNContainer.
protected class	EmbeddedEPNManager.EPNTask This class implements the task for dispatching the event list to the node.

Nested classes/interfaces inherited from class org.overlord.bam.epn.AbstractEPNManager

AbstractEPNManager.NetworkList

Field Summary

Fields inherited from interface org.overlord.bam.epn.EPNManager

URI

Constructor Summary

EmbeddedEPNManager()

Method Summary

void	close() This method closes the manager.
protected void	currentNetworkChanged(Network oldNet, Network newNet) This method is called to handle a change in the current version of a network, due to a new (more recent) version being registered or a current version being unregistered.
protected EPNContainer	getContainer() This method returns the Event Processor Network Container.
protected Map<String,List<EmbeddedEPNManager.EmbeddedChannel>>	getEntryPoints() This method provides access to the registered channels against subjects.
protected void	publish(String subject, EventList events) This method publishes the event list to the specific subject.
void	publish(String subject, List<? extends Serializable> events) This method publishes the supplied events to be processed by any network subscribed to the nominated subject.
protected void	registerEntryPoints(Network network) This method registers the network's entry point against its list of subscription subjects.
protected void	unregisterEntryPoints(Network network) This method unregisters the entry points associated with the supplied network.

Methods inherited from class org.overlord.bam.epn.AbstractEPNManager

addNetworkListener, addNodeListener, dispatchNotificationToListeners, getNetwork, getNetworksForSubject, getNode, notifyListeners, postProcessEvents, preProcessEvents, preProcessEvents, process, register, registerSubjects, removeNetworkListener, removeNodeListener, setLastAccessed, setUsePrePostEventListProcessing, unregister, unregisterSubjects

Methods inherited from class java.lang.Object

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

Constructor Detail

EmbeddedEPNManager

public EmbeddedEPNManager()

Method Detail

getContainer

protected EPNContainer getContainer()

This method returns the Event Processor Network Container.

Specified by:

getContainer in class AbstractEPNManager

Returns:

The container

getEntryPoints

protected Map<String,List<EmbeddedEPNManager.EmbeddedChannel>> getEntryPoints()

This method provides access to the registered channels against subjects.

Returns:

The entry points

currentNetworkChanged

protected void currentNetworkChanged(Network oldNet,
                                     Network newNet)

This method is called to handle a change in the current version of a network, due to a new (more recent) version being registered or a current version being unregistered.

Overrides:

currentNetworkChanged in class AbstractEPNManager

Parameters:

oldNet - The old network version

newNet - The new network version

unregisterEntryPoints

protected void unregisterEntryPoints(Network network)

This method unregisters the entry points associated with the supplied network.

Parameters:

network - The network

registerEntryPoints

protected void registerEntryPoints(Network network)

This method registers the network's entry point against its list of subscription subjects.

Parameters:

network - The network

publish

public void publish(String subject,
                    List<? extends Serializable> events)
             throws Exception

This method publishes the supplied events to be processed by any network subscribed to the nominated subject.

Parameters:

subject - The subject upon which to publish the events

events - The list of events to be processed

Throws:

Exception - Failed to publish the events

publish

protected void publish(String subject,
                       EventList events)
                throws Exception

This method publishes the event list to the specific subject.

Parameters:

subject - The subject

events - The events

Throws:

Exception - Failed to publish events

close

public void close()
           throws Exception

This method closes the manager.

Specified by:

close in interface EPNManager

Overrides:

close in class AbstractEPNManager

Throws:

Exception - Failed to close manager