public class EmbeddedEPNManager extends AbstractEPNManager
Modifier and Type | Class and Description |
---|---|
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.
|
AbstractEPNManager.NetworkList
Constructor and Description |
---|
EmbeddedEPNManager() |
Modifier and Type | Method and Description |
---|---|
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.
|
addNetworkListener, addNotificationListener, dispatchNotificationToListeners, getNetwork, getNetworksForSubject, getNode, getValidationListener, init, isManaged, notifyListeners, postProcessEvents, preProcessEvents, preProcessEvents, process, register, registerSubjects, removeNetworkListener, removeNotificationListener, setLastAccessed, setUsePrePostEventListProcessing, unregister, unregisterSubjects
protected EPNContainer getContainer()
getContainer
in class AbstractEPNManager
protected Map<String,List<EmbeddedEPNManager.EmbeddedChannel>> getEntryPoints()
protected void currentNetworkChanged(Network oldNet, Network newNet)
currentNetworkChanged
in class AbstractEPNManager
oldNet
- The old network versionnewNet
- The new network versionprotected void unregisterEntryPoints(Network network)
network
- The networkprotected void registerEntryPoints(Network network)
network
- The networkpublic void publish(String subject, List<? extends Serializable> events) throws Exception
subject
- The subject upon which to publish the eventsevents
- The list of events to be processedException
- Failed to publish the eventsprotected void publish(String subject, EventList events) throws Exception
subject
- The subjectevents
- The eventsException
- Failed to publish eventspublic void close() throws Exception
close
in interface EPNManager
close
in class AbstractEPNManager
Exception
- Failed to close managerCopyright © 2013-2015 JBoss by Red Hat. All Rights Reserved.