Package | Description |
---|---|
org.overlord.rtgov.active.collection.epn | |
org.overlord.rtgov.epn | |
org.overlord.rtgov.epn.embedded | |
org.overlord.rtgov.epn.jms |
Modifier and Type | Method and Description |
---|---|
protected void |
EPNActiveCollectionSource.aggregateEvents(String subject,
EventList events)
This method processes the notification to aggregate information over a
particular duration.
|
void |
EPNActiveCollectionSource.EPNACSNotificationListener.handleEvents(String subject,
EventList events)
This method notifies the listener when a situation occurs
on the subject for the identified network/version/node
concerning a list of events.
|
protected void |
EPNActiveCollectionSource.processNotification(String subject,
EventList events)
This method processes the notification to update the active collection
accordingly.
|
Modifier and Type | Method and Description |
---|---|
protected EventList |
Node.process(EPNContainer container,
String source,
EventList events,
int retriesLeft)
Deprecated.
The container should be associated with the node using the 'setContainer' method
|
protected EventList |
AbstractEPNManager.process(Network network,
Node node,
String source,
EventList events,
int retriesLeft)
This method dispatches a set of events directly to the supplied
node.
|
protected EventList |
Node.process(String source,
EventList events,
int retriesLeft)
This method processes the supplied list of events against the
event processor configured with the node, to determine
which transformed events should be forwarded, and which need
to be returned to be retried.
|
Modifier and Type | Method and Description |
---|---|
protected void |
AbstractEPNManager.dispatchNotificationToListeners(String subject,
EventList events)
This method dispatches the notifications to the registered listeners.
|
protected void |
Node.forward(EPNContainer container,
EventList results)
Deprecated.
Use the alternative 'forward' method that does not require the container to be provided
|
protected void |
Node.forward(EventList results)
This method forwards the results to any destinations that have been
defined.
|
abstract void |
ContextualNotificationListener.handleEvents(String subject,
EventList events)
This method notifies the listener when a situation occurs
on the subject for the identified network/version/node
concerning a list of events.
|
void |
NotificationListener.notify(String subject,
EventList events)
This method notifies the listener when events occurs
on the identified subject.
|
void |
ContextualNotificationListener.notify(String subject,
EventList events)
This method notifies the listener when a situation occurs
on the identified network/version/node concerning a list
of events.
|
protected void |
AbstractEPNManager.notifyListeners(String subject,
EventList events)
This method sends a notification to any registered listeners that
a situation has occurred associated with the specified subject.
|
protected void |
AbstractEPNManager.postProcessEvents(EventList events)
This method resets the events, to enable them to be used in the
context of another classloader.
|
protected void |
AbstractEPNManager.preProcessEvents(EventList events,
ClassLoader classloader)
This method deserializes the events in the context of the supplied
classloader.
|
protected void |
AbstractEPNManager.preProcessEvents(EventList events,
Network network)
This method deserializes the events in the context of the supplied
network.
|
protected EventList |
Node.process(EPNContainer container,
String source,
EventList events,
int retriesLeft)
Deprecated.
The container should be associated with the node using the 'setContainer' method
|
protected EventList |
AbstractEPNManager.process(Network network,
Node node,
String source,
EventList events,
int retriesLeft)
This method dispatches a set of events directly to the supplied
node.
|
protected EventList |
Node.process(String source,
EventList events,
int retriesLeft)
This method processes the supplied list of events against the
event processor configured with the node, to determine
which transformed events should be forwarded, and which need
to be returned to be retried.
|
void |
EPNContainer.send(EventList events,
List<Channel> channels)
This method sends the supplied events to the supplied list
of channels.
|
Modifier and Type | Method and Description |
---|---|
protected void |
EmbeddedEPNManager.publish(String subject,
EventList events)
This method publishes the event list to the specific subject.
|
void |
EmbeddedEPNManager.EmbeddedChannel.send(EventList events) |
void |
EmbeddedEPNManager.EmbeddedChannel.send(EventList events,
int retriesLeft) |
void |
EmbeddedEPNManager.EmbeddedEPNContainer.send(EventList events,
List<Channel> channels)
This method sends the supplied events to the supplied list
of channels.
|
Constructor and Description |
---|
EmbeddedEPNManager.EPNTask(Network network,
Node node,
String source,
EventList events,
int retriesLeft,
EmbeddedEPNManager.EmbeddedChannel channel)
This is the constructor for the task.
|
Modifier and Type | Method and Description |
---|---|
protected void |
JMSEPNManagerImpl.dispatch(Network network,
Node node,
String source,
EventList events,
int retriesLeft)
This method dispatches a set of events directly to the supplied
network and node.
|
protected void |
JMSEPNManagerImpl.dispatchToNodes(String networkName,
String version,
String nodeList,
String source,
EventList events,
int retriesLeft)
This method dispatches the events to the list of nodes that are associated with
the named network.
|
protected void |
JMSEPNManagerImpl.dispatchToSubjects(String subjectList,
EventList events)
This method dispatches the events to any network that has subscribed to any one of
the supplied list of subjects.
|
protected void |
JMSEPNManagerImpl.notifyListeners(String subject,
EventList events)
This method sends a notification to any registered listeners that
a situation has occurred associated with the specified subject.
|
protected void |
JMSEPNManagerImpl.retry(String networkName,
String version,
String nodeName,
String source,
EventList events,
int retriesLeft)
This method handles retrying the supplied set of events, if the number of
retries left is greater than 0.
|
void |
JMSChannel.send(EventList events) |
void |
JMSChannel.send(EventList events,
int retriesLeft) |
void |
JMSEPNManagerImpl.JMSEPNContainer.send(EventList events,
List<Channel> channels)
This method sends the supplied events to the supplied list
of channels.
|
Copyright © 2013-2015 JBoss by Red Hat. All Rights Reserved.