Index

A C D E G H I L M N O P R S T U V 
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
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.
A C D E G H I L M N O P R S T U V 
All Classes and Interfaces|All Packages|Constant Field Values|Serialized Form