Index
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
A
- AbstractChainManager - Class in com.softwareag.connectivity.chainmanagers
-
Base class for a manager that takes responsibility for dynamically creating and managing instances of a transport plug-in.
- AbstractChainManager(Logger, ChainManagerConstructorParameters) - Constructor for class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
Constructor.
- AbstractCodec - Class in com.softwareag.connectivity
-
Base class for codec plug-ins.
- AbstractCodec(Logger, PluginConstructorParameters.CodecConstructorParameters) - Constructor for class com.softwareag.connectivity.AbstractCodec
-
Constructor.
- AbstractSimpleCodec - Class in com.softwareag.connectivity
-
Base class that allows simplified implementation of codec plug-ins.
- AbstractSimpleCodec(Logger, PluginConstructorParameters.CodecConstructorParameters) - Constructor for class com.softwareag.connectivity.AbstractSimpleCodec
-
Constructor.
- AbstractSimpleTransport - Class in com.softwareag.connectivity
-
Base class that allows simplified implementation of transport plug-ins.
- AbstractSimpleTransport(Logger, PluginConstructorParameters.TransportConstructorParameters) - Constructor for class com.softwareag.connectivity.AbstractSimpleTransport
-
Constructor.
- AbstractTransport - Class in com.softwareag.connectivity
-
Base class for transport plug-ins.
- AbstractTransport(Logger, PluginConstructorParameters.TransportConstructorParameters) - Constructor for class com.softwareag.connectivity.AbstractTransport
-
Constructor.
- addChannelLifecycleListener(ChannelLifecycleListener, String) - Method in interface com.softwareag.connectivity.chainmanagers.ChainManagerHost
-
Register a listener to get a callback when interested channel is created/destroyed.
- ApplicationJar - Annotation Interface in com.apama.epl.plugin.annotation
-
This annotation provides application-level information about a jar that contains one or more EPL plug-ins, such as additional entries to add to the classpath.
- author() - Element in annotation interface com.apama.epl.plugin.annotation.ApplicationJar
-
Deprecated.
C
- Callback - Annotation Interface in com.apama.epl.plugin.annotation
-
Declare methods on a correlator Java plugin as being a callback from the runtime.
- Callback.CBType - Enum Class in com.apama.epl.plugin.annotation
- Chain - Interface in com.softwareag.connectivity.chainmanagers
-
Represents a dynamic chain instance, created using
ChainManagerHost.createChain(java.lang.String, com.softwareag.connectivity.chainmanagers.ChainDefinition, java.util.Map<java.lang.String, java.lang.String>, java.lang.String, java.util.List<java.lang.String>)
. - ChainDefinition - Class in com.softwareag.connectivity.chainmanagers
-
A dynamic chain definition, providing the configuration for each plug-in in a chain.
- ChainDefinition(String, List<ChainDefinition.PluginConfiguration>) - Constructor for class com.softwareag.connectivity.chainmanagers.ChainDefinition
-
Creates a new chain definition from scratch.
- ChainDefinition.PluginConfiguration - Class in com.softwareag.connectivity.chainmanagers
-
The name and configuration of a single plug-in in a chain definition.
- chainDefinitions - Variable in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
The configuration of the dynamic chain definitions that contain the transport associated with this manager.
- chainId - Variable in class com.softwareag.connectivity.ConnectivityPlugin
-
The identifier used for the chain this plug-in is part of.
- ChainManagerConstructorParameters - Interface in com.softwareag.connectivity.chainmanagers
-
A container for parameters passed to the constructor of a dynamic chain manager.
- ChainManagerHost - Interface in com.softwareag.connectivity.chainmanagers
-
Interface that the host provides to the chain manager for operations such as creating chains and registering channel lifecycle listeners.
- Channel - Class in com.apama.epl.plugin
-
Class that holds a channel reference and can be passed across the correlator EPL/Java plugin boundary.
- Channel() - Constructor for class com.apama.epl.plugin.Channel
-
The default constructor.
- Channel(Channel) - Constructor for class com.apama.epl.plugin.Channel
-
Copy constructor
- Channel(Context) - Constructor for class com.apama.epl.plugin.Channel
-
Create a Channel that wraps a Context
- Channel(String) - Constructor for class com.apama.epl.plugin.Channel
-
Create a Channel wrapping a channel name
- CHANNEL - Static variable in class com.softwareag.connectivity.Message
-
The metadata key for the channel name.
- ChannelLifecycleListener - Interface in com.softwareag.connectivity.chainmanagers
-
Interface that will be implemented by a chain manager to get callbacks on channel creation and destroy.
- checkNoItemsRemaining() - Method in class com.softwareag.connectivity.util.MapExtractor
-
Checks that all entries in this map have been read (using one of the get methods on this class), and throws an exception listing the unexpected items that were not read if there are any.
- classpath() - Element in annotation interface com.apama.epl.plugin.annotation.ApplicationJar
-
Specifies the classpath that will be used for the classloader of this application.
- clear() - Method in class com.softwareag.connectivity.NamedMap
-
Clear the map and name.
- clearAll() - Method in interface com.softwareag.connectivity.StatusReporter
-
Remove all status values set by this reporter.
- clone() - Method in class com.apama.epl.plugin.Channel
- clone() - Method in class com.apama.epl.plugin.Context
- clone() - Method in class com.softwareag.connectivity.Message
-
Create a copy of this Message.
- clone() - Method in class com.softwareag.connectivity.NamedMap
- com.apama.epl.plugin - package com.apama.epl.plugin
- com.apama.epl.plugin.annotation - package com.apama.epl.plugin.annotation
- com.softwareag.connectivity - package com.softwareag.connectivity
- com.softwareag.connectivity.chainmanagers - package com.softwareag.connectivity.chainmanagers
- com.softwareag.connectivity.util - package com.softwareag.connectivity.util
- company() - Element in annotation interface com.apama.epl.plugin.annotation.ApplicationJar
-
Deprecated.
- config - Variable in class com.softwareag.connectivity.ConnectivityPlugin
-
Configuration of this plug-in.
- CONNECTIVITY_API_VERSION - Static variable in class com.softwareag.connectivity.ConnectivityPlugin
-
A string constant containing the 4-digit version number for this API.
- ConnectivityPlugin - Class in com.softwareag.connectivity
-
Base class that all codec and transport plug-ins inherit from.
- Context - Class in com.apama.epl.plugin
-
Class that holds a context reference and can be passed across the correlator EPL/Java plugin boundary.
- Context() - Constructor for class com.apama.epl.plugin.Context
-
The default constructor.
- Context(Context) - Constructor for class com.apama.epl.plugin.Context
-
Copy constructor
- CONTROL_TYPE - Static variable in class com.softwareag.connectivity.Message
-
The metadata key indicating that a message is a control message, and what its type is.
- CONTROL_TYPE_ACK_REQUIRED - Static variable in class com.softwareag.connectivity.Message
-
Name of the AckRequired control message, a towards-host control message.
- CONTROL_TYPE_ACK_UPTO - Static variable in class com.softwareag.connectivity.Message
-
Name of the AckUpTo control message, a towards-transport control message in response to AckRequired, containing the corresponding MESSAGE_ID.
- CONTROL_TYPE_FLUSH - Static variable in class com.softwareag.connectivity.Message
-
Name of the Flush control message, a towards-transport control message.
- CONTROL_TYPE_FLUSH_ACK - Static variable in class com.softwareag.connectivity.Message
-
Name of the FlushAck control message, a towards-host control message in response to Flush, containing the corresponding REQUEST_ID.
- copy() - Method in class com.softwareag.connectivity.Message
-
Create a copy of this Message.
- Correlator - Class in com.apama.epl.plugin
-
Static class to allow java plugins to interact with the correlator.
- createChain(String, ChainDefinition, Map<String, String>, String, List<String>) - Method in interface com.softwareag.connectivity.chainmanagers.ChainManagerHost
-
Create a new instance of a dynamic chain.
- createStatusItem(String, long) - Method in interface com.softwareag.connectivity.StatusReporter
-
Creates a StatusItem interface that can be used to report status for a given key.
- createStatusItem(String, String) - Method in interface com.softwareag.connectivity.StatusReporter
-
Creates a StatusItem interface that can be used to report status for a given key.
- createTransport(Logger, ManagedTransportConstructorParameters) - Method in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
Called by the connectivity framework creation of each chain, to request the manager to create and return a new instance of its associated transport.
D
- deliverMessageTowardsTransport(Message) - Method in class com.softwareag.connectivity.AbstractSimpleTransport
-
Deliver an individual non-null message.
- deliverNullPayloadTowardsTransport(Message) - Method in class com.softwareag.connectivity.AbstractSimpleTransport
-
Deliver an individual null-payload message.
- description() - Element in annotation interface com.apama.epl.plugin.annotation.ApplicationJar
-
Deprecated.
- description() - Element in annotation interface com.apama.epl.plugin.annotation.EPLPlugin
-
Enables the author to specify a description of the Plugin (meta info for human consumption).
- destroy() - Method in interface com.softwareag.connectivity.chainmanagers.Chain
-
Delete this dynamic chain instance, shutting down all plug-ins in the chain.
- Direction - Enum Class in com.softwareag.connectivity
-
The enumeration indicating the direction of message flow - towards the transport or towards the host.
E
- empty() - Method in class com.apama.epl.plugin.Channel
-
Returns true iff this wraps an empty context i.e.
- enableReliability(Direction) - Method in interface com.softwareag.connectivity.PluginHost
-
Enable reliable messaging for the chain that this plug-in belongs to, in a particular direction i.e.
- EPLPlugin - Annotation Interface in com.apama.epl.plugin.annotation
-
This Annotation is used to mark a Java EPL Plugin class.
- equals(Object) - Method in class com.apama.epl.plugin.Channel
- equals(Object) - Method in class com.apama.epl.plugin.Context
- equals(Object) - Method in class com.softwareag.connectivity.NamedMap
- EventHandler - Interface in com.apama.epl.plugin
-
Handler interface used for callbacks when a plugin listens for events on a channel.
G
- get(Object, Class<T>) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a value of the specified type, throwing an exception if it has the wrong type, a null value or is not present.
- get(Object, Class<T>, T) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a value of the specified type, returning a default value if not present or null, and throwing an exception if it has the wrong type.
- get(Object, T) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a value of the specified type, returning a default value if not present or null, and throwing an exception if it has the wrong type.
- getChainDefinition() - Method in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
Helper method to get the chain definition containing the transport associated with this manager, assuming there is only one.
- getChainDefinition(String) - Method in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
Helper method to get the chain definition matching the specified id, or a singleton chain definition if no id was specified (null or empty).
- getChainDefinitionId() - Method in class com.softwareag.connectivity.chainmanagers.ChainDefinition
- getChainDefinitions() - Method in interface com.softwareag.connectivity.chainmanagers.ChainManagerConstructorParameters
- getChainId() - Method in interface com.softwareag.connectivity.PluginConstructorParameters
- getChainManagerHost() - Method in interface com.softwareag.connectivity.chainmanagers.ChainManagerConstructorParameters
- getConfig() - Method in interface com.softwareag.connectivity.PluginConstructorParameters
-
Get the configuration for this plug-in.
- getConfiguration() - Method in class com.softwareag.connectivity.chainmanagers.ChainDefinition.PluginConfiguration
- getCurrent() - Static method in class com.apama.epl.plugin.Context
-
Returns a reference to the context the plugin is currently being called from.
- getDefaultChannelTowardsHost() - Method in interface com.softwareag.connectivity.chainmanagers.ManagedTransportConstructorParameters
-
Get the default channel used on this chain for messages sent from the transport towards the host.
- getDisplayName() - Method in class com.softwareag.connectivity.util.MapExtractor
-
Retrieve the display name associated with this map.
- getId() - Method in class com.apama.epl.plugin.Context
-
Equivalent to the EPL method getId on the context type
- getKey() - Method in interface com.softwareag.connectivity.StatusReporter.StatusItem
-
Get the unique key specified when this status item was created
- getList(Object, Class<T>, boolean) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a list where each item has the same type.
- getListOfMaps(Object, boolean) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a list where each item is a Map, each wrapped in its own MapExtractor for simplified access.
- getListOfMaps(Object, boolean, boolean) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a list where each item is a Map, each wrapped in its own MapExtractor for simplified access.
- getManagerConfig() - Method in interface com.softwareag.connectivity.chainmanagers.ChainManagerConstructorParameters
-
Get the configuration for this manager.
- getManagerName() - Method in interface com.softwareag.connectivity.chainmanagers.ChainManagerConstructorParameters
- getMap(Object, boolean) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a value of type Map, wrapped in a new MapExtractor.
- getMetadata() - Method in class com.softwareag.connectivity.Message
-
Deprecated.
- getMetadataMap() - Method in class com.softwareag.connectivity.Message
-
Get the metadata for this message as a map.
- getName() - Method in class com.apama.epl.plugin.Context
-
Returns the name of the context.
- getName() - Method in class com.softwareag.connectivity.NamedMap
-
Get the event type name of the map.
- getPayload() - Method in class com.softwareag.connectivity.Message
-
Get the payload object.
- getPluginHost() - Method in interface com.softwareag.connectivity.PluginConstructorParameters
- getPluginName() - Method in class com.softwareag.connectivity.chainmanagers.ChainDefinition.PluginConfiguration
- getPluginName() - Method in interface com.softwareag.connectivity.PluginConstructorParameters
- getPlugins() - Method in class com.softwareag.connectivity.chainmanagers.ChainDefinition
- getStatus() - Method in interface com.softwareag.connectivity.StatusReporter.StatusItem
-
Return the value this status item was set to most recently by this class.
- getStatusReporter() - Method in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
Allows reporting status information from this plug-in, such as connected/disconnected status and number of messages sent/received in each direction.
- getStatusReporter() - Method in interface com.softwareag.connectivity.chainmanagers.ChainManagerConstructorParameters
- getStatusReporter() - Method in class com.softwareag.connectivity.ConnectivityPlugin
-
Allows reporting status information from this plug-in, such as connected/disconnected status and number of messages sent/received in each direction.
- getStatusReporter() - Method in interface com.softwareag.connectivity.PluginConstructorParameters
- getStringAllowEmpty(Object) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a string value; if the value is an empty string it will be returned, if the value is missing or null an exception is thrown.
- getStringAllowEmpty(Object, String) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a string value; if the value is an empty string it will be returned, if the value is missing or null the specified defaultValue is returned.
- getStringDisallowEmpty(Object) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a string value; if the value is an empty string, null or missing an exception is thrown.
- getStringDisallowEmpty(Object, String) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get a string value; if the value is an empty string, null or missing the defaultValue will be returned instead.
- getSubscribeChannels() - Method in interface com.softwareag.connectivity.chainmanagers.ManagedTransportConstructorParameters
-
Get the channels that the chain containing this transport instance is subscribed to for receiving messages from the host towards the transport.
- getTransport() - Method in interface com.softwareag.connectivity.chainmanagers.Chain
-
Get the transport plug-in at the end of the chain.
- getTransport(Class<T>) - Method in interface com.softwareag.connectivity.chainmanagers.Chain
-
Get the transport plug-in at the end of the chain.
- getTransportConfig() - Method in class com.softwareag.connectivity.chainmanagers.ChainDefinition
- getTransportPluginName() - Method in interface com.softwareag.connectivity.chainmanagers.ChainManagerConstructorParameters
- getUnderlyingMap() - Method in class com.softwareag.connectivity.util.MapExtractor
-
Get the Map object that this extractor refers to.
H
- handleEvent(String, String) - Method in interface com.apama.epl.plugin.EventHandler
- handleException(Exception, Message, boolean) - Method in class com.softwareag.connectivity.AbstractSimpleCodec
-
Handle an exception thrown from transforming messages.
- handleException(Exception, Message, boolean) - Method in class com.softwareag.connectivity.AbstractSimpleTransport
-
Handle exception thrown from delivering messages.
- hashCode() - Method in class com.apama.epl.plugin.Channel
- hashCode() - Method in class com.apama.epl.plugin.Context
- hashCode() - Method in class com.softwareag.connectivity.NamedMap
- host - Variable in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
The interface through which the host provides services required by chain managers.
- host - Variable in class com.softwareag.connectivity.ConnectivityPlugin
-
Interface to support miscellaneous requests from this plug-in to the host system.
- HOST_MESSAGE_TYPE - Static variable in class com.softwareag.connectivity.Message
-
The metadata key for the type of message; its meaning is host-specific.
- hostReady() - Method in class com.softwareag.connectivity.AbstractCodec
-
No-op implementation of
ConnectivityPlugin.hostReady()
. - hostReady() - Method in class com.softwareag.connectivity.AbstractTransport
-
No-op implementation of
ConnectivityPlugin.hostReady()
. - hostReady() - Method in class com.softwareag.connectivity.ConnectivityPlugin
-
Called some time after
ConnectivityPlugin.start()
, when the host is ready to start receiving messages. - hostSide - Variable in class com.softwareag.connectivity.AbstractCodec
-
The next plug-in in the chain towards host, as set by
AbstractCodec.setNextTowardsHost(HostSide)
. - hostSide - Variable in class com.softwareag.connectivity.AbstractTransport
-
The next plug-in in the chain towards host, as set by
AbstractTransport.setNextTowardsHost(HostSide)
. - HostSide - Interface in com.softwareag.connectivity
-
Used by transport and codec plug-in authors for sending messages towards the host (originating from the transport).
I
- increment() - Method in interface com.softwareag.connectivity.StatusReporter.StatusItem
-
Set an integer status value by incrementing the previous integer value that was set by this object.
- increment(long) - Method in interface com.softwareag.connectivity.StatusReporter.StatusItem
-
Set an integer status value by incrementing the previous integer value that was set by this object.
- isEmpty() - Method in class com.softwareag.connectivity.util.MapExtractor
-
Returns true if the map is empty.
- isPublic() - Method in class com.apama.epl.plugin.Context
-
Returns true if the context is public (receives external / enqueued events)
- isShuttingDown() - Method in interface com.softwareag.connectivity.PluginHost
-
Check if host is shutting down.
- iterator() - Method in class com.softwareag.connectivity.util.MapExtractor
-
Iterates over the keys (non-deterministic order).
L
- logger - Variable in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
A slf4j logger to be used by this manager for anything which needs to be written to the host's log.
- logger - Variable in class com.softwareag.connectivity.ConnectivityPlugin
-
A slf4j logger to be used by this plug-in instance for anything which needs to be written to the host's log.
M
- ManagedTransportConstructorParameters - Interface in com.softwareag.connectivity.chainmanagers
-
A container for parameters used to create a transport plug-in instance from a chain manager.
- managerName - Variable in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
The name used in the configuration file for this dynamic chain manager.
- MapExtractor - Class in com.softwareag.connectivity.util
-
Provides a type-safe way to extract values from a heterogenous Map (where keys and values could be of any type), with user-friendly error messages identifying the map and key within the map if any item is missing or has the wrong type.
- MapExtractor(Map<?, ?>, String) - Constructor for class com.softwareag.connectivity.util.MapExtractor
-
Create a new instance wrapping the specified map.
- Message - Class in com.softwareag.connectivity
-
A container for a payload and metadata.
- Message(Object) - Constructor for class com.softwareag.connectivity.Message
-
Create a message with the given payload.
- Message(Object, Map<String, ?>) - Constructor for class com.softwareag.connectivity.Message
-
Create a message with the given payload and metadata
- MESSAGE_ID - Static variable in class com.softwareag.connectivity.Message
-
The metadata key used for unique identification of towards-host messages.
N
- name() - Element in annotation interface com.apama.epl.plugin.annotation.ApplicationJar
-
Name of this application jar, used by engine_delete and in some log messages.
- name() - Element in annotation interface com.apama.epl.plugin.annotation.EPLPlugin
-
Enables the author to specify the EPL import name for the plugin.
- NamedMap<K,
V> - Class in com.softwareag.connectivity -
Extension to HashMap to give the map an event type name.
- NamedMap() - Constructor for class com.softwareag.connectivity.NamedMap
-
Construct an empty Map with a null name.
- NamedMap(int) - Constructor for class com.softwareag.connectivity.NamedMap
-
Construct a map with the supplied initial capacity and null name.
- NamedMap(int, float) - Constructor for class com.softwareag.connectivity.NamedMap
-
Construct a map with the supplied initial capacity and load factor and null name.
- NamedMap(String) - Constructor for class com.softwareag.connectivity.NamedMap
-
Construct an empty Map with the supplied event type name.
- NamedMap(String, int) - Constructor for class com.softwareag.connectivity.NamedMap
-
Construct a map with the supplied name and initial capacity.
- NamedMap(String, int, float) - Constructor for class com.softwareag.connectivity.NamedMap
-
Construct a map with the supplied name, initial capacity and load factor.
- NamedMap(String, Map<? extends K, ? extends V>) - Constructor for class com.softwareag.connectivity.NamedMap
-
Construct a map from the supplied name and underlying Map.
- NamedMap(Map<? extends K, ? extends V>) - Constructor for class com.softwareag.connectivity.NamedMap
-
Construct a map from the supplied name and null name.
- NoBlock - Annotation Interface in com.apama.epl.plugin.annotation
-
Declare that either an entire plugin, or a specific method doesn't block.
O
- onChannelCreated(String, Direction) - Method in interface com.softwareag.connectivity.chainmanagers.ChannelLifecycleListener
-
Called by the host when a channel is created.
- onChannelDestroyed(String, Direction) - Method in interface com.softwareag.connectivity.chainmanagers.ChannelLifecycleListener
-
Called by the host when a channel is destroyed.
P
- PluginConfiguration(String, Map<String, Object>) - Constructor for class com.softwareag.connectivity.chainmanagers.ChainDefinition.PluginConfiguration
-
Creates a PluginConfiguration instance.
- PluginConstructorParameters - Interface in com.softwareag.connectivity
-
A base interface for parameters passed to the constructor of transport or codec plug-ins.
- PluginConstructorParameters.CodecConstructorParameters - Interface in com.softwareag.connectivity
-
A container for parameters passed to the constructor of a codec plug-in.
- PluginConstructorParameters.TransportConstructorParameters - Interface in com.softwareag.connectivity
-
A container for parameters passed to the constructor of a transport plug-in.
- PluginHost - Interface in com.softwareag.connectivity
-
Interface to support miscellaneous requests from a particular plug-in to the host system.
- pluginMethodBlocking() - Static method in class com.apama.epl.plugin.Correlator
-
Methods declared as non-blocking can opt to block by calling this method.
- pluginName - Variable in class com.softwareag.connectivity.ConnectivityPlugin
-
The name used in the configuration file for this plug-in.
- put(Object, Object) - Method in class com.softwareag.connectivity.util.MapExtractor
-
Adds or replaces an item in the underlying map.
- putMetadataValue(String, Object) - Method in class com.softwareag.connectivity.Message
-
Put the specified key,value pair into the metadata for this message.
R
- REQUEST_ID - Static variable in class com.softwareag.connectivity.Message
-
The metadata key used for unique identification of towards-transport control messages, with a value of type Long.
S
- sendBatchTowardsHost(List<Message>) - Method in class com.softwareag.connectivity.AbstractSimpleCodec
-
Transform a batch of messages and pass them on to the next plug-in synchronously.
- sendBatchTowardsHost(List<Message>) - Method in interface com.softwareag.connectivity.HostSide
-
Process or deliver a batch of messages heading towards the host.
- sendBatchTowardsTransport(List<Message>) - Method in class com.softwareag.connectivity.AbstractSimpleCodec
-
Transform a batch of messages and pass them on to the next plug-in synchronously.
- sendBatchTowardsTransport(List<Message>) - Method in class com.softwareag.connectivity.AbstractSimpleTransport
-
Deliver a batch of messages and pass them on to the next plug-in synchronously.
- sendBatchTowardsTransport(List<Message>) - Method in interface com.softwareag.connectivity.TransportSide
-
Process or deliver a batch of messages heading towards a plug-in transport.
- sendTo(String, Channel) - Static method in class com.apama.epl.plugin.Correlator
-
Sends the supplied string to the specified Channel.
- sendTo(String, Context) - Static method in class com.apama.epl.plugin.Correlator
-
Sends the supplied string to the specified context.
- sendTo(String, Context...) - Static method in class com.apama.epl.plugin.Correlator
-
Sends the supplied string to the specified contexts.
- sendTo(String, String) - Static method in class com.apama.epl.plugin.Correlator
-
Sends the supplied string to the specified channel name.
- setName(String) - Method in class com.softwareag.connectivity.NamedMap
-
Set the event type name of the Map.
- setNextTowardsHost(HostSide) - Method in class com.softwareag.connectivity.AbstractCodec
-
Remember the host side of this codec.
- setNextTowardsHost(HostSide) - Method in class com.softwareag.connectivity.AbstractTransport
-
Remember the host side of this transport.
- setNextTowardsTransport(TransportSide) - Method in class com.softwareag.connectivity.AbstractCodec
-
Remember the transport side of this codec.
- setPayload(Object) - Method in class com.softwareag.connectivity.Message
-
Set the payload object.
- setStatus(long) - Method in interface com.softwareag.connectivity.StatusReporter.StatusItem
-
Set an integer status value.
- setStatus(String) - Method in interface com.softwareag.connectivity.StatusReporter.StatusItem
-
Set a string status value.
- setStatus(Map<String, String>) - Method in interface com.softwareag.connectivity.StatusReporter
-
Set multiple related string status values at the same time (atomically).
- shutdown() - Method in class com.softwareag.connectivity.AbstractCodec
-
No-op implementation of
ConnectivityPlugin.shutdown()
. - shutdown() - Method in class com.softwareag.connectivity.AbstractTransport
-
Close any resources created by the plug-in, and terminate and join any background threads.
- shutdown() - Method in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
Called during host shutdown to indicate that the chain manager should stop any background processes and disconnect any remote connections.
- shutdown() - Method in class com.softwareag.connectivity.ConnectivityPlugin
-
Close any resources created by the connectivity plug-in, and terminate and join any background threads.
- SHUTDOWN - Enum constant in enum class com.apama.epl.plugin.annotation.Callback.CBType
- start() - Method in class com.softwareag.connectivity.AbstractCodec
-
No-op implementation of
ConnectivityPlugin.start()
. - start() - Method in class com.softwareag.connectivity.AbstractTransport
-
No-op implementation of
ConnectivityPlugin.start()
. - start() - Method in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
Called after the chain manager is created to indicate that it can register a channel lifecycle listener, make external connections, create threads, and create chains.
- start() - Method in interface com.softwareag.connectivity.chainmanagers.Chain
-
Calls start on all of the plug-ins in the chain and connects the chain to receive events.
- start() - Method in class com.softwareag.connectivity.ConnectivityPlugin
-
Called when an entire chain has been created.
- STATUS_FAILED - Static variable in interface com.softwareag.connectivity.StatusReporter
-
A constant that should be used as the status value when a component is not currently operational due to an error condition.
- STATUS_ONLINE - Static variable in interface com.softwareag.connectivity.StatusReporter
-
A constant that should be used as the status value when a component is online, operational, connected, and ready to handles messages.
- STATUS_STARTING - Static variable in interface com.softwareag.connectivity.StatusReporter
-
A constant that should be used as the status value when a component is still starting, i.e.
- StatusReporter - Interface in com.softwareag.connectivity
-
An interface allowing a plug-in to report status values to the host.
- StatusReporter.StatusItem - Interface in com.softwareag.connectivity
-
An interface that can be used to efficiently update the value associated with a single status key.
- subscribe(EventHandler, String...) - Static method in class com.apama.epl.plugin.Correlator
-
Subscribes a callback handler for events sent to the given channels.
T
- toString() - Method in class com.apama.epl.plugin.Channel
-
Returns a string representation of the channel instance.
- toString() - Method in class com.apama.epl.plugin.Context
-
Returns a string representation of the context instance.
- toString() - Method in class com.softwareag.connectivity.AbstractCodec
- toString() - Method in class com.softwareag.connectivity.AbstractTransport
- toString() - Method in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
- toString() - Method in class com.softwareag.connectivity.chainmanagers.ChainDefinition.PluginConfiguration
- toString() - Method in class com.softwareag.connectivity.chainmanagers.ChainDefinition
- toString() - Method in class com.softwareag.connectivity.Message
-
Return a string representation of the message metadata and payload.
- toString() - Method in class com.softwareag.connectivity.NamedMap
- toString() - Method in class com.softwareag.connectivity.util.MapExtractor
-
A string representation of this object including both the display name and map contents.
- toString(boolean) - Method in class com.softwareag.connectivity.Message
-
Return a string representation of the message metadata and payload.
- TOWARDS_HOST - Enum constant in enum class com.softwareag.connectivity.Direction
-
The direction of messages flowing towards the host (from the transport).
- TOWARDS_TRANSPORT - Enum constant in enum class com.softwareag.connectivity.Direction
-
The direction of messages flowing towards the transport (from the host).
- transformMessageTowardsHost(Message) - Method in class com.softwareag.connectivity.AbstractSimpleCodec
-
Transform an individual message with a non-null payload.
- transformMessageTowardsTransport(Message) - Method in class com.softwareag.connectivity.AbstractSimpleCodec
-
Transform an individual message with a non-null payload.
- transformNullPayloadTowardsHost(Message) - Method in class com.softwareag.connectivity.AbstractSimpleCodec
-
Transform an individual message that has a null payload.
- transformNullPayloadTowardsTransport(Message) - Method in class com.softwareag.connectivity.AbstractSimpleCodec
-
Transform an individual message that has a null payload.
- transportPluginName - Variable in class com.softwareag.connectivity.chainmanagers.AbstractChainManager
-
The name used in the configuration file for the transport plug-in that created this chain manager.
- transportSide - Variable in class com.softwareag.connectivity.AbstractCodec
-
The next plug-in in the chain towards transport, as set by
AbstractCodec.setNextTowardsTransport(TransportSide)
. - TransportSide - Interface in com.softwareag.connectivity
-
Used by codec plug-in authors for sending messages towards the transport (originating from the host).
- type() - Element in annotation interface com.apama.epl.plugin.annotation.Callback
U
- unsubscribe(EventHandler) - Static method in class com.apama.epl.plugin.Correlator
-
Unsubscribes a handler from all channels.
- unsubscribe(EventHandler, String...) - Static method in class com.apama.epl.plugin.Correlator
-
Unsubscribes a handler from some channels.
V
- valueOf(String) - Static method in enum class com.apama.epl.plugin.annotation.Callback.CBType
-
Returns the enum constant of this class with the specified name.
- valueOf(String) - Static method in enum class com.softwareag.connectivity.Direction
-
Returns the enum constant of this class with the specified name.
- values() - Static method in enum class com.apama.epl.plugin.annotation.Callback.CBType
-
Returns an array containing the constants of this enum class, in the order they are declared.
- values() - Static method in enum class com.softwareag.connectivity.Direction
-
Returns an array containing the constants of this enum class, in the order they are declared.
- version() - Element in annotation interface com.apama.epl.plugin.annotation.ApplicationJar
-
Deprecated.
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form
Message.getMetadataMap()
instead