Package | Description |
---|---|
org.overlord.rtgov.epn | |
org.overlord.rtgov.epn.embedded | |
org.overlord.rtgov.epn.jms | |
org.overlord.rtgov.epn.util | |
org.overlord.rtgov.epn.validation |
Modifier and Type | Method and Description |
---|---|
Network |
AbstractEPNManager.NetworkList.getCurrent()
This method returns the most recent instance of the network.
|
protected Network |
AbstractEPNManager.getNetwork(String name,
String version)
This method returns the network associated with the
supplied name.
|
Network |
AbstractEPNManager.NetworkList.getVersion(String version)
This method returns the network instance associated with
the supplied version.
|
Modifier and Type | Method and Description |
---|---|
List<Network> |
AbstractEPNManager.NetworkList.getNetworks()
This method returns the list of networks.
|
protected List<Network> |
AbstractEPNManager.getNetworksForSubject(String subject)
This method returns the list of networks that subscribe to
the supplied subject.
|
Modifier and Type | Method and Description |
---|---|
void |
AbstractEPNManager.NetworkList.add(Network network)
This method adds a new instance of the Network to the list.
|
protected void |
AbstractEPNManager.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.
|
Channel |
EPNContainer.getChannel(Network network,
String source,
String dest)
This method returns the channel associated with the supplied
destination.
|
Channel |
EPNContainer.getNotificationChannel(Network network,
String subject)
This method returns the notification channel associated with
the supplied network and source.
|
protected void |
AbstractEPNLoader.preInit(Network network)
This method pre-initializes the network before it is
registered with the container.
|
protected void |
AbstractEPNManager.preProcessEvents(EventList events,
Network network)
This method deserializes the events in the context of the supplied
network.
|
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.
|
void |
EPNManager.register(Network network)
This method registers a network.
|
void |
AbstractEPNManager.register(Network network)
This method registers a network.
|
void |
NetworkListener.registered(Network network)
This method indicates that a network has been
registered.
|
protected void |
AbstractEPNManager.registerSubjects(Network network)
This method registers the supplied network against the
subjects it is interested in.
|
void |
AbstractEPNManager.NetworkList.remove(Network network)
This method removes an instance of the Network from the list.
|
protected void |
AbstractEPNManager.setLastAccessed(Network network,
long timestamp)
This method sets the last accessed timestamp on the supplied
network.
|
void |
NetworkListener.unregistered(Network network)
This method indicates that a network has been
unregistered.
|
protected void |
AbstractEPNManager.unregisterSubjects(Network network)
This method unregisters the supplied network from the
subjects it is interested in.
|
Modifier and Type | Method and Description |
---|---|
protected void |
EmbeddedEPNManager.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.
|
Channel |
EmbeddedEPNManager.EmbeddedEPNContainer.getChannel(Network network,
String source,
String dest)
This method returns the channel associated with the supplied
destination.
|
Channel |
EmbeddedEPNManager.EmbeddedEPNContainer.getNotificationChannel(Network network,
String subject)
This method returns the notification channel associated with
the supplied network and source.
|
protected void |
EmbeddedEPNManager.registerEntryPoints(Network network)
This method registers the network's entry point against its
list of subscription subjects.
|
protected void |
EmbeddedEPNManager.unregisterEntryPoints(Network network)
This method unregisters the entry points associated with the supplied
network.
|
Constructor and Description |
---|
EmbeddedEPNManager.EmbeddedChannel(Network network,
Node node,
String source)
The constructor for publishing events between nodes in a network.
|
EmbeddedEPNManager.EmbeddedChannel(Network network,
String subject)
The constructor for the notification channel.
|
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.
|
Channel |
JMSEPNManagerImpl.JMSEPNContainer.getChannel(Network network,
String source,
String dest)
This method returns the channel associated with the supplied
destination.
|
Channel |
JMSEPNManagerImpl.JMSEPNContainer.getNotificationChannel(Network network,
String subject)
This method returns the notification channel associated with
the supplied network and source.
|
Constructor and Description |
---|
JMSChannel(javax.jms.Session session,
javax.jms.MessageProducer producer,
Network network,
String subject,
boolean notification)
This is the constructor for the JMS channel.
|
JMSChannel(javax.jms.Session session,
javax.jms.MessageProducer producer,
Network network,
String sourceNode,
String destNode)
This is the constructor for the JMS channel.
|
Modifier and Type | Method and Description |
---|---|
static Network |
NetworkUtil.deserialize(byte[] epn)
This method deserializes an Event Processor Network from a JSON representation.
|
Modifier and Type | Method and Description |
---|---|
static byte[] |
NetworkUtil.serialize(Network epn)
This method serializes an Event Processor Network into a JSON representation.
|
Modifier and Type | Method and Description |
---|---|
protected static boolean |
EPNValidator.checkCyclicDependency(Network epn,
List<String> path,
String node,
EPNValidationListener l)
This method determines whether there is a cyclic dependency.
|
void |
EPNValidationListener.error(Network epn,
Object target,
String issue)
This method identifies an issue with a part of
an Event Processor Network.
|
static boolean |
EPNValidator.validate(Network epn,
EPNValidationListener l)
This method validates the supplied network and
returns results via a supplied listener.
|
protected static boolean |
EPNValidator.validateNetwork(Network epn,
EPNValidationListener l)
This method validates the network.
|
protected static boolean |
EPNValidator.validateNodes(Network epn,
EPNValidationListener l)
This method validates the network nodes.
|
protected static boolean |
EPNValidator.validateNotifications(Network epn,
Node node,
EPNValidationListener l)
This method validates the notifications associated with the supplied network
and node.
|
protected static boolean |
EPNValidator.validateSubscriptions(Network epn,
EPNValidationListener l)
This method validates the network subscriptions.
|
Copyright © 2013-2015 JBoss by Red Hat. All Rights Reserved.