- AbstractEventCodec - Class in com.apama.iaf.plugin
-
AbstractEventCodec is the abstract base class which all Java IAF event
codecs should extend.
- AbstractEventCodec(String, EventCodecProperty[], TimestampConfig) - Constructor for class com.apama.iaf.plugin.AbstractEventCodec
-
Construct a new instance of AbstractEventCodec.
- AbstractEventTransport - Class in com.apama.iaf.plugin
-
AbstractEventTransport is the abstract base class which all Java IAF event
transports should extend.
- AbstractEventTransport(String, EventTransportProperty[], TimestampConfig) - Constructor for class com.apama.iaf.plugin.AbstractEventTransport
-
Construct a new instance of AbstractEventTransport.
- AbstractGenericComponentManagementBean - Class in com.apama.net.beans
-
AbstractGenericComponentManagementBean is a JavaBean that provides a base
class upon which JavaBeans using the remote GenericComponentManagement can
be built.
- AbstractGenericComponentManagementBean() - Constructor for class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Default constructor - as required to be a bean.
- AbstractGenericComponentManagementBean(String, int, String) - Constructor for class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Full argument constructor.
- AbstractStore - Class in com.apama.correlator.memstore
-
A named distributed 'store' instance, which is a factory for tables
and typically encapsulates a connection to a single distributed cluster.
- AbstractStore(String) - Constructor for class com.apama.correlator.memstore.AbstractStore
-
Create a store.
- AbstractStoreFactory - Class in com.apama.correlator.memstore
-
Factory object for creating store objects, and holding the configuration properties requried to do so.
- AbstractStoreFactory() - Constructor for class com.apama.correlator.memstore.AbstractStoreFactory
-
- AbstractTable - Class in com.apama.correlator.memstore
-
A table exposed by a distributed store, providing the ability to get and modify the Rows that hold the
key/value data held by the cache.
- AbstractTable() - Constructor for class com.apama.correlator.memstore.AbstractTable
-
Creates a table.
- add(String, String) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Add a new name-value pair to the event.
- addChannel(String, Map<String, Object>) - Method in interface com.apama.services.event.IEventService
-
Create an EventServiceChannel specifically for listening to a given
channel or channels.
- addClusterMembershipListener(ClusterMembershipListener) - Method in class com.apama.correlator.memstore.AbstractStore
-
Adds a new cluster membership listener callback.
- addColumn(String, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Add a column to a data table.
- addConfiguration(int, NormalisedEvent) - Method in interface com.apama.iaf.plugin.ConfigurableCodec
-
A codec may wish to support multiple configurations depending on
data being read.
- addConsumer(String, String...) - Method in class com.apama.engine.beans.EngineClientBean
-
Add a new uniquely-named synchronous consumer that listens on a specified set of
channels.
- addConsumer(String, String[], boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Add a new uniquely-named consumer that listens on a specified set of
channels.
- addConsumer(String, String[], boolean, boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Add a new uniquely-named consumer that listens on a specified set of
channels.
- addConsumer(String, String...) - Method in interface com.apama.engine.beans.interfaces.ReceiveConsumerOperationsInterface
-
Add a new uniquely-named consumer that listens on a specified set of channels.
- addConsumer(String, String[], boolean) - Method in interface com.apama.engine.beans.interfaces.ReceiveConsumerOperationsInterface
-
Add a new uniquely-named consumer that listens on a specified set of channels.
- addConsumer(String, String[], boolean, boolean) - Method in interface com.apama.engine.beans.interfaces.ReceiveConsumerOperationsInterface
-
Add a new uniquely-named consumer that listens on a specified set of channels.
- addEventDecoder(String, EventDecoder) - Method in class com.apama.iaf.plugin.AbstractEventTransport
-
Add a named event decoder to the set of decoders known to the
transport.
- addEventListener(IEventListener) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Add a listener that will be notified whenever events are received on any
of the channels on which this consumer is listening.
- addEventListener(IEventListener) - Method in interface com.apama.services.event.IEventServiceChannel
-
Add an IEventListener that will be notified of every event (of a
pre-registered type) that is received by this EventServiceChannel instance.
- addEventListener(IEventListener, EventType) - Method in interface com.apama.services.event.IEventServiceChannel
-
Add an IEventListener that will be notified of every event, of the
specified EventType, that is received by this EventServiceChannel instance.
- addEventTransport(String, EventTransport) - Method in class com.apama.iaf.plugin.AbstractEventCodec
-
Add a named event transport to the set of transports known to the
codec.
- addField(Field<?>) - Method in class com.apama.event.parser.EventType
-
Method to append extra field to the EventType.
- addField(String, FieldType<T>) - Method in class com.apama.event.parser.EventType
-
Method to append extra field to the EventType.
- addListener(PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Add a PropertyChangeListener that will be notified of changes to any
bound property of this object.
- addListener(String, PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Add a PropertyChangeListener that will be notified of changes to a
specific named bound property of this object.
- addListener(PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioInstance
-
Add a listener to the list of those interested in changes to any
object property, or any scenario instance (input and/or output) parameter.
- addListener(String, PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioInstance
-
Add a listener to the list of those interested in changes to the
object property with given name, or the scenario instance (input and/or
output) parameter with the given name.
- addListener(PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioService
-
Add a PropertyChangeListener that will be notified of changes to any
bound property of this object.
- addListener(String, PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioService
-
Add a PropertyChangeListener that will be notified of changes to a
specific named bound property of this object.
- addMatchListener(MatchListener) - Method in class com.apama.jmon.EventExpression
-
Add a listener to be notified when the match occurs for this event expression.
- addMatchListener(MatchListener) - Method in class com.apama.jmon.PreparedEventExpression
-
Add a listener to be notified when the match occurs for this event
expression.
- addNow(Integer) - Method in class com.apama.util.TimestampSet
-
Add a new index-time pair to the event.
- addPropertyChangeListener(PropertyChangeListener) - Method in class com.apama.engine.beans.EngineClientBean
-
- addPropertyChangeListener(String, PropertyChangeListener) - Method in class com.apama.engine.beans.EngineClientBean
-
- addPropertyChangeListener(PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Add a property change listener.
- addPropertyChangeListener(String, PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Add a property change listener for a specific named property.
- addPropertyChangeListener(PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Add a property change listener.
- addPropertyChangeListener(String, PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Add a property change listener for a specific named property.
- addPropertyChangeListener(PropertyChangeListener) - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Add a property change listener.
- addPropertyChangeListener(String, PropertyChangeListener) - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Add a property change listener for a specific named property.
- addPropertyChangeListener(PropertyChangeListener) - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Add a property change listener.
- addPropertyChangeListener(String, PropertyChangeListener) - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Add a property change listener for a specific named property.
- addPropertyChangeListener(PropertyChangeListener) - Method in class com.apama.net.beans.PingBean
-
Add a property change listener.
- addPropertyChangeListener(String, PropertyChangeListener) - Method in class com.apama.net.beans.PingBean
-
Add a property change listener for a specific named property.
- addPropertyChangeListener(String, PropertyChangeListener) - Method in interface com.apama.services.event.IEventService
-
Add a change listener for the specified property.
- addPropertyChangeListenerSync(PropertyChangeListener) - Method in class com.apama.engine.beans.EngineClientBean
-
- addPropertyChangeListenerSync(String, PropertyChangeListener) - Method in class com.apama.engine.beans.EngineClientBean
-
- addPropertyChangeListenerSync(PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Deprecated.
Use addPropertyChangeListener instead
- addPropertyChangeListenerSync(String, PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Deprecated.
Use addPropertyChangeListener instead
- addPropertyChangeListenerSync(PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Deprecated.
Use addPropertyChangeListener instead
- addPropertyChangeListenerSync(String, PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Deprecated.
Use addPropertyChangeListener instead
- addQuick(String, String) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Add a new name-value pair to the event.
- addRow(String) - Method in interface com.apama.dashboard.data.ITabularData
-
Add a new row to the data table.
- addRowChangedListener() - Method in class com.apama.correlator.memstore.notifications.RowChangedSubscriptionManager
-
Register with the distributed table so that row changed notifications can be fired on this object.
- addSubscription(long, long) - Method in class com.apama.correlator.memstore.notifications.RowChangedSubscriptionManager
-
Adds a subscription.
- addTime(Integer, Double) - Method in class com.apama.util.TimestampSet
-
Add a new index-time pair to the timestamp.
- addValidationFailureMessage(String, String) - Method in exception com.apama.services.scenario.InvalidInputParameterException
-
Add a localized validation failure message for a named input parameter.
- afterPropertiesSet() - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
Validates the configuration properties at the end of the initialization process.
- ALL_STR - Static variable in class com.apama.util.Logger
-
- AP_TIMESTAMP_DOWNSTREAM_CLIENT_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CLIENT_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_APPLICATION_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_APPLICATION_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_INPUT_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_INPUT_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_OUTPUT_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_OUTPUT_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_RESERVED1_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_RESERVED1_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_RESERVED2_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_RESERVED2_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_SERVICE_MONITOR_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_CORRELATOR_SERVICE_MONITOR_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_IAF_APAMA_ENTRY - Static variable in class com.apama.util.TimestampSet
-
Not currently implemented, do not use.
- AP_TIMESTAMP_DOWNSTREAM_IAF_APAMA_EXIT - Static variable in class com.apama.util.TimestampSet
-
Not currently implemented, do not use.
- AP_TIMESTAMP_DOWNSTREAM_IAF_DECODER_ENTRY - Static variable in class com.apama.util.TimestampSet
-
Optionally implemented by a codec, represents the time a message from the transport enters the codec.
- AP_TIMESTAMP_DOWNSTREAM_IAF_DECODER_EXIT - Static variable in class com.apama.util.TimestampSet
-
Optionally implemented by a codec, represents the time a normalised event leaves the codec (for the semantic mapper).
- AP_TIMESTAMP_DOWNSTREAM_IAF_MAPPER_ENTRY - Static variable in class com.apama.util.TimestampSet
-
Represents the time a normalised event enters the semantic mapper before being sent to the Correlator.
- AP_TIMESTAMP_DOWNSTREAM_IAF_MAPPER_EXIT - Static variable in class com.apama.util.TimestampSet
-
Represents the time a normalised event leaves the semantic mapper before being sent to the Correlator.
- AP_TIMESTAMP_DOWNSTREAM_IAF_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_IAF_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_IAF_TRANSPORT_ENTRY - Static variable in class com.apama.util.TimestampSet
-
Optionally implemented by a transport, represents the time a message from the external system is received by the transport.
- AP_TIMESTAMP_DOWNSTREAM_IAF_TRANSPORT_EXIT - Static variable in class com.apama.util.TimestampSet
-
Optionally implemented by a transport, represents the time a message leaves the transport.
- AP_TIMESTAMP_DOWNSTREAM_MERGE_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_MERGER_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_SENDER_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_DOWNSTREAM_SENDER_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CLIENT_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CLIENT_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_APPLICATION_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_APPLICATION_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_INPUT_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_INPUT_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_OUTPUT_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_OUTPUT_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_RESERVED1_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_RESERVED1_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_RESERVED2_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_RESERVED2_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_SERVICE_MONITOR_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_CORRELATOR_SERVICE_MONITOR_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_IAF_APAMA_ENTRY - Static variable in class com.apama.util.TimestampSet
-
Not currently implemented, do not use.
- AP_TIMESTAMP_UPSTREAM_IAF_APAMA_EXIT - Static variable in class com.apama.util.TimestampSet
-
Not currently implemented, do not use.
- AP_TIMESTAMP_UPSTREAM_IAF_ENCODER_ENTRY - Static variable in class com.apama.util.TimestampSet
-
Optionally implemented by a codec, represents the time a normalised event from the semantic mapper enters the codec.
- AP_TIMESTAMP_UPSTREAM_IAF_ENCODER_EXIT - Static variable in class com.apama.util.TimestampSet
-
Optionally implemented by a codec, represents the time a normalised event leaves the codec.
- AP_TIMESTAMP_UPSTREAM_IAF_MAPPER_ENTRY - Static variable in class com.apama.util.TimestampSet
-
Represents the time an Apama event from the Correlator enters the semantic mapper.
- AP_TIMESTAMP_UPSTREAM_IAF_MAPPER_EXIT - Static variable in class com.apama.util.TimestampSet
-
Represents the time an Apama event from the Correlator leaves the semantic mapper.
- AP_TIMESTAMP_UPSTREAM_IAF_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_IAF_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_IAF_TRANSPORT_ENTRY - Static variable in class com.apama.util.TimestampSet
-
Optionally implemented by a transport, represents the time a message from the codec enters the transport.
- AP_TIMESTAMP_UPSTREAM_IAF_TRANSPORT_EXIT - Static variable in class com.apama.util.TimestampSet
-
Optionally implemented by a transport, represents the time a message leaves the transport and is to sent to the external system.
- AP_TIMESTAMP_UPSTREAM_MERGER_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_MERGER_MIN - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_SENDER_MAX - Static variable in class com.apama.util.TimestampSet
-
- AP_TIMESTAMP_UPSTREAM_SENDER_MIN - Static variable in class com.apama.util.TimestampSet
-
- API_VERSION - Static variable in interface com.apama.iaf.plugin.EventCodec
-
Codec API version.
- API_VERSION - Static variable in interface com.apama.iaf.plugin.EventTransport
-
Transport API version.
- Application - Annotation Type in com.apama.jmon.annotation
-
This Annotation is used to document a JMON application.
- assertAssignable(Object, String) - Method in class com.apama.event.parser.BooleanFieldType
-
- assertAssignable(Object, String) - Method in class com.apama.event.parser.ChannelFieldType
-
- assertAssignable(Object, String) - Method in class com.apama.event.parser.DecimalFieldType
-
- assertAssignable(Object, String) - Method in class com.apama.event.parser.DictionaryFieldType
-
- assertAssignable(Object, String) - Method in class com.apama.event.parser.EventType
-
- assertAssignable(Object, String) - Method in class com.apama.event.parser.FieldType
-
This method is intended for internal use only and may be removed at any time - do not use.
- assertAssignable(Object, String) - Method in class com.apama.event.parser.FloatFieldType
-
- assertAssignable(Object, String) - Method in class com.apama.event.parser.IntegerFieldType
-
- assertAssignable(Object, String) - Method in class com.apama.event.parser.LocationFieldType
-
- assertAssignable(Object, String) - Method in class com.apama.event.parser.SequenceFieldType
-
- assertAssignable(Object, String) - Method in class com.apama.event.parser.StringFieldType
-
- asyncRequestResponse(IResponseListener, Event, EventType) - Method in interface com.apama.services.event.IEventServiceChannel
-
Emulate an asynchronous RPC call to the Correlator by sending an event,
and then invoking a callback when a matching response event is received
(non-blocking call).
- asyncRequestResponse(IResponseListener, Event, EventType, long) - Method in interface com.apama.services.event.IEventServiceChannel
-
Emulate an asynchronous RPC call to the Correlator by sending an event,
and then invoking a callback when a matching response event is received
(non-blocking call, with timeout).
- attachAsConsumerOfEngine(EngineClientBean, String[]) - Method in class com.apama.engine.beans.EngineClientBean
-
- attachAsConsumerOfEngine(String, int, String[]) - Method in class com.apama.engine.beans.EngineClientBean
-
- attachAsConsumerOfEngine(String, int, String[], boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
- attachAsConsumerOfEngine(String, int, String[], boolean, ConnectMode) - Method in class com.apama.engine.beans.EngineClientBean
-
- attachAsConsumerOfEngine(EngineClientBean, String[]) - Method in interface com.apama.engine.beans.interfaces.ConnectOperationsInterface
-
Connect this engine to another (non-persisently) so that it receives
events emitted on the specified channels.
- attachAsConsumerOfEngine(String, int, String[]) - Method in interface com.apama.engine.beans.interfaces.ConnectOperationsInterface
-
Connect this engine to another (non-persistently) so that it receives
events emitted on the specified channels.
- attachAsConsumerOfEngine(String, int, String[], boolean) - Method in interface com.apama.engine.beans.interfaces.ConnectOperationsInterface
-
Connect this engine to another so that it receives events emitted on
the specified channels.
- attachAsConsumerOfEngine(String, int, String[], boolean, ConnectMode) - Method in interface com.apama.engine.beans.interfaces.ConnectOperationsInterface
-
Connect this engine to another so that it receives events emitted on
the specified channels.
- attachAsEventConsumerTo(EngineManagement, String[]) - Method in interface com.apama.engine.EngineManagement
-
Connect another Engine to this one as an event supplier, with this
engine consuming its events.
- attachAsEventConsumerTo(EngineManagement, String[], boolean) - Method in interface com.apama.engine.EngineManagement
-
Connect another Engine to this one as an event supplier, with this
engine consuming its events.
- attachAsEventConsumerTo(EngineManagement, String[], boolean, ConnectMode) - Method in interface com.apama.engine.EngineManagement
-
Connect another Engine to this one as an event supplier, with this
engine consuming its events.
- attachAsEventConsumerTo(String, int, String[]) - Method in interface com.apama.engine.EngineManagement
-
Connect another Engine to this one as an event supplier, with this
engine consuming its events, and the receiver should reconnect if it is disconnected.
- attachAsEventConsumerTo(String, int, String[], boolean) - Method in interface com.apama.engine.EngineManagement
-
Connect another Engine to this one as an event supplier, with this
engine consuming its events, and the receiver should reconnect if it is disconnected.
- attachAsEventConsumerTo(String, int, String[], boolean, ConnectMode) - Method in interface com.apama.engine.EngineManagement
-
Connect another Engine to this one as an event supplier, with this
engine consuming its events, and the receiver should reconnect if it is disconnected.
- Callback - Annotation Type in com.apama.epl.plugin.annotation
-
Declare methods on a correlator Java plugin as being a callback from the runtime.
- Callback.CBType - Enum in com.apama.epl.plugin.annotation
-
- canConnectNow(EngineClientInterface) - Method in interface com.apama.engine.beans.interfaces.ReconnectPolicyInterface
-
decide whether the given bean should be allowed to reconnect now
- canCreate(IUserCredentials, IScenarioDefinition) - Method in interface com.apama.dashboard.security.IScenarioAuthority
-
Test if a user has rights to create a scenario instance.
- canDecodeString(String, ParameterTypeEnum) - Static method in enum com.apama.services.scenario.ParameterTypeEnum
-
Utility method to check whether a string representation of a parameter value (in the format used by the Correlator) can be
converted to a Java object, based on its type identifier.
- canDelete(IUserCredentials, IScenarioInstance) - Method in interface com.apama.dashboard.security.IScenarioAuthority
-
Test if a user has rights to delete a scenario instance.
- canEdit(IUserCredentials, IScenarioInstance) - Method in interface com.apama.dashboard.security.IScenarioAuthority
-
Test if a user has rights to edit a scenario instance.
- canSend(IUserCredentials, Event) - Method in interface com.apama.dashboard.security.IEventAuthority
-
Test if a user has rights to send an event.
- canView(IUserCredentials, IScenarioInstance) - Method in interface com.apama.dashboard.security.IScenarioAuthority
-
Test if a user has rights to view a scenario instance.
- 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(String) - Constructor for class com.apama.epl.plugin.Channel
-
Create a Channel wrapping a channel name
- Channel(Context) - Constructor for class com.apama.epl.plugin.Channel
-
Create a Channel that wraps a Context
- Channel(Channel) - Constructor for class com.apama.epl.plugin.Channel
-
Copy constructor
- ChannelConfig - Class in com.apama.services.event
-
ChannelConfig is a helper class that assists in building a properies map
for use when creating a new EventServiceChannel via the IEventService.addChannel() method.
- ChannelFieldType - Class in com.apama.event.parser
-
Represents the Apama Channel
type,
for which values are specified as String
objects.
- cleanup() - Method in class com.apama.iaf.plugin.AbstractEventCodec
-
Frees any resources allocated by the codec (useful for resources
external to the JVM that were allocated in the constructor).
- cleanup() - Method in class com.apama.iaf.plugin.AbstractEventTransport
-
Frees any resources allocated by the transport (useful for resources
external to the JVM that were allocated in the constructor).
- clear() - Method in class com.apama.correlator.memstore.AbstractTable
-
Removes all of the mappings from this map (optional operation).
- clear() - Method in class com.apama.correlator.memstore.ConcurrentMapAdapter
-
- clear() - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Removes all mappings from this map.
- clear() - Method in class com.apama.util.TimestampSet
-
Removes all mappings from this map.
- clearProcessingQueue() - Method in interface com.apama.services.event.IEventServiceChannel
-
Immediately remove (discard) all events from the internal processing queue.
- clearRemovedRows() - Method in interface com.apama.dashboard.data.ITabularData
-
Clear all removed rows from the data table.
- clone() - Method in class com.apama.correlator.memstore.RowValue
-
Clone the values that represent this RowValue into a new RowValue
- clone() - Method in interface com.apama.dashboard.data.ITabularData
-
Create a copy of the data table.
- clone() - Method in class com.apama.epl.plugin.Channel
-
- clone() - Method in class com.apama.epl.plugin.Context
-
- clone() - Method in class com.apama.jmon.Context
-
- clone() - Method in class com.apama.jmon.Event
-
- clone() - Method in class com.apama.jmon.Location
-
- close() - Method in class com.apama.correlator.memstore.AbstractStore
-
Disposes of all resources associated with this store, including shutting down background
threads, terminating network connections, etc.
- close() - Method in class com.apama.correlator.memstore.AbstractTable
-
Closes resources allocated by this table such as the RowChangedSubscriptionManager.
- ClusterMembershipListener - Interface in com.apama.correlator.memstore
-
Listener interface for notification of changes in the membership of a cluster.
- CodecException - Exception in com.apama.iaf.plugin
-
CodecException is the exception class thrown by a Java IAF Codec plugin.
- CodecException(String) - Constructor for exception com.apama.iaf.plugin.CodecException
-
Constructs a CodecException from a string message describing the
error, and assumes an error code of INTERNALERROR.
- CodecException(String, int) - Constructor for exception com.apama.iaf.plugin.CodecException
-
Constructs a CodecException from a string message describing the
error and a numeric code representing the class of error.
- CodecException(String, Throwable) - Constructor for exception com.apama.iaf.plugin.CodecException
-
Constructs a CodecException from a string message describing the
error, and an exception object that is the cause of the error.
- CodecException(String, Throwable, int) - Constructor for exception com.apama.iaf.plugin.CodecException
-
Constructs a CodecException from a string message describing the
error, a numeric code representing the class of error and an exception
object that is the cause of the error.
- CodecStatus - Class in com.apama.iaf.plugin
-
CodecStatus contains status information about the codec, and is
returned by AbstractCodecEvent.getStatus().
- CodecStatus(String, long, long) - Constructor for class com.apama.iaf.plugin.CodecStatus
-
Constructs a CodecStatus instance with the specified parameters.
- COL_TYPE_BOOLEAN - Static variable in interface com.apama.dashboard.data.ITabularData
-
Column of type Boolean
- COL_TYPE_DATE - Static variable in interface com.apama.dashboard.data.ITabularData
-
Column of type Date
- COL_TYPE_DOUBLE - Static variable in interface com.apama.dashboard.data.ITabularData
-
Column of type Double
- COL_TYPE_FLOAT - Static variable in interface com.apama.dashboard.data.ITabularData
-
Column of type Float
- COL_TYPE_INTEGER - Static variable in interface com.apama.dashboard.data.ITabularData
-
Column of type Integer
- COL_TYPE_LONG - Static variable in interface com.apama.dashboard.data.ITabularData
-
Column of type Long
- COL_TYPE_STRING - Static variable in interface com.apama.dashboard.data.ITabularData
-
Column of type String
- com.apama - package com.apama
-
- com.apama.adapters.el.api - package com.apama.adapters.el.api
-
- com.apama.correlator.jms.config.api.mapper - package com.apama.correlator.jms.config.api.mapper
-
- com.apama.correlator.memstore - package com.apama.correlator.memstore
-
- com.apama.correlator.memstore.notifications - package com.apama.correlator.memstore.notifications
-
- com.apama.dashboard - package com.apama.dashboard
-
- com.apama.dashboard.command - package com.apama.dashboard.command
-
- com.apama.dashboard.data - package com.apama.dashboard.data
-
- com.apama.dashboard.function - package com.apama.dashboard.function
-
- com.apama.dashboard.security - package com.apama.dashboard.security
-
- com.apama.engine - package com.apama.engine
-
- com.apama.engine.beans - package com.apama.engine.beans
-
- com.apama.engine.beans.interfaces - package com.apama.engine.beans.interfaces
-
- com.apama.epl.plugin - package com.apama.epl.plugin
-
- com.apama.epl.plugin.annotation - package com.apama.epl.plugin.annotation
-
- com.apama.event - package com.apama.event
-
- com.apama.event.parser - package com.apama.event.parser
- com.apama.iaf.plugin - package com.apama.iaf.plugin
-
- com.apama.jmon - package com.apama.jmon
-
- com.apama.jmon.annotation - package com.apama.jmon.annotation
-
- com.apama.net - package com.apama.net
-
- com.apama.net.beans - package com.apama.net.beans
-
- com.apama.net.beans.interfaces - package com.apama.net.beans.interfaces
-
- com.apama.net.interfaces - package com.apama.net.interfaces
-
- com.apama.services.event - package com.apama.services.event
-
- com.apama.services.scenario - package com.apama.services.scenario
-
- com.apama.util - package com.apama.util
-
- CommandDescriptorFactory - Class in com.apama.dashboard.command
-
CommandDescriptorFactory is a class that provides factory methods for
creating new instances of classes that implement the ICommandDescriptor
interface.
- CommandDescriptorFactory() - Constructor for class com.apama.dashboard.command.CommandDescriptorFactory
-
- CommunicationException - Exception in com.apama.services.event
-
CommunicationException is a specialized exception for use with the Event
Service that indicates that there is a problem communicating with the
Correlator.
- CommunicationException(String) - Constructor for exception com.apama.services.event.CommunicationException
-
- CommunicationException(String, Throwable) - Constructor for exception com.apama.services.event.CommunicationException
-
- CommunicationException(Throwable) - Constructor for exception com.apama.services.event.CommunicationException
-
- ConcurrentMapAdapter<K,V> - Class in com.apama.correlator.memstore
-
Helper class for implementing the distributed MemoryStore AbstractTable class
using an instance of ConcurrentMap, which is exposed by many providers.
- ConcurrentMapAdapter(ConcurrentMap<K, V>, RowKeyValueConverter<K, V>) - Constructor for class com.apama.correlator.memstore.ConcurrentMapAdapter
-
Create a table implementation that handles all accessor methods by calling the supplied map,
translating keys and values via the supplied converter.
- ConcurrentMapAdapter(ConcurrentMap<K, V>) - Constructor for class com.apama.correlator.memstore.ConcurrentMapAdapter
-
Create a table implementation that handles all accessor methods by calling the supplied map,
translating keys and values by casting to/from String (for keys) and RowValue (for row values).
- CONFIG_ACKDATA_TIMEOUT - Static variable in interface com.apama.services.scenario.IScenarioService
-
Configuration property name specifying the the timeout between receiving
an Acknowledge for an operation (Create, Edit, Delete) and seeing the
response (Created, Edited, Delted) on the Data channel.
- CONFIG_AUTO_INSTANCE_DISCOVERY - Static variable in interface com.apama.services.scenario.IScenarioService
-
Configuration property name specifying whether to automatically
initiate discovery of all scenario instances upon creating a
scenario service.
- CONFIG_DEFAULT_REQUEST_RESPONSE_TIMEOUT - Static variable in interface com.apama.services.event.IEventServiceChannel
-
Configuration property name for specifying the default request-response timeout that
a new EventServiceChannel should use.
- CONFIG_DISCONNECT_IF_SLOW - Static variable in interface com.apama.services.scenario.IScenarioService
-
Configuration property name specifying whether to connect to the data source
signalling that we may be disconnected if we do not keep up with events.
- CONFIG_ENFORCE_RESPONSE_SEQUENCING - Static variable in interface com.apama.services.event.IEventServiceChannel
-
Configuration property name for specifying if a new EventServiceChannel should use
strict response sequencing for synchronous request-response invocations.
- CONFIG_FILTER_USER - Static variable in interface com.apama.services.scenario.IScenarioService
-
Configuration property name specifying whether to only list to updates
for the specified user
If present, the scenario(s) listened for must have the ConfigureUpdates
property sendRawUser or sendThrottledUser set to true.
- CONFIG_INBOUND_EVENT_QUEUE_SOFT_REFERENCE_PREFIXES - Static variable in interface com.apama.services.event.IEventServiceChannel
-
Configuration property name for specifying for which event names a new
EventServiceChannel should use SoftReferences in the inbound queue.
- CONFIG_MESSAGEID_FIELD_NAME - Static variable in interface com.apama.services.event.IEventServiceChannel
-
Configuration property name for specifying the field name of message ID's (for
request-response) that a new EventServiceChannel should use.
- CONFIG_RECONNECT_PERIOD - Static variable in interface com.apama.services.scenario.IScenarioService
-
Configuration property name specifying how long to wait (in milliseconds, at a minimum)
between reconnects.
- CONFIG_SCENARIO_EXCLUSION_FILTER - Static variable in interface com.apama.services.scenario.IScenarioService
-
Configuration property name for specifying a Set of ScenarioID's (Strings)
that the client wishes to exclude.
- CONFIG_SCENARIO_INCLUSION_FILTER - Static variable in interface com.apama.services.scenario.IScenarioService
-
Configuration property name for specifying a Set of ScenarioID's (Strings) in
which the client is interested.
- CONFIG_STRONG_DATA_INBOUND_EVENT_QUEUE - Static variable in interface com.apama.services.scenario.IScenarioService
-
Configuration property name for specifying if the EventServiceChannels created
for listening to ScenarioInstance updates (the 'Data' channel)
should use strong or soft references to events in the inbound queue.
- CONFIG_USE_RAW_DATA_CHANNEL - Static variable in interface com.apama.services.scenario.IScenarioService
-
Configuration property name for specifying if the EventServiceChannels created
for listening to ScenarioInstance updates (the 'Data' channel)
should be subscribed to the normal Data channel (possibly throttled),
or the Raw Data channel (always unthrottled).
- ConfigurableCodec - Interface in com.apama.iaf.plugin
-
This interface defines functions that Codecs which have upstream events
passed to them via their associated transport must perform.
- connectEventConsumer(EventConsumer, String[]) - Method in interface com.apama.engine.EngineManagement
-
Connect an event receiver to the Engine.
- connectEventConsumer(EventConsumer, String[], boolean) - Method in interface com.apama.engine.EngineManagement
-
Connect an event receiver to the Engine.
- connectInBackground() - Method in class com.apama.engine.beans.EngineClientBean
-
Requests that the bean begins to establish a connection automatically in the background.
- connectInBackground() - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Requests that the client begins to establish a connection in the background.
- ConnectionConstants - Interface in com.apama.net
-
- ConnectMode - Enum in com.apama.engine
-
- connectNow() - Method in class com.apama.engine.beans.EngineClientBean
-
Manually request that the bean connects to the remote server.
- connectNow() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Manually request that the bean connects to the remote server.
- connectNow() - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Manually request that the bean connects to the remote server.
- connectNow() - Method in class com.apama.net.beans.PingBean
-
Manually request that the bean connects to the remote server.
- ConnectOperationsInterface - Interface in com.apama.engine.beans.interfaces
-
ConnectOperationsInterface is an interface that specifies methods for
connecting an engine as a consumer of another engine.
- connectToEngine(String, int) - Static method in class com.apama.engine.EngineManagementFactory
-
This static method attempts to establish a connection to an
Engine.
- connectToEngine(String, int, String) - Static method in class com.apama.engine.EngineManagementFactory
-
This static method attempts to establish a connection to an
Engine.
- connectToEngine(String, int, String, String[]) - Static method in class com.apama.engine.EngineManagementFactory
-
This static method attempts to establish a connection to an
Engine.
- connectToEngineMonitorOnly(String, int, String) - Static method in class com.apama.engine.EngineManagementFactory
-
Attempt to establish a monitor-only connection to an Engine listening
on the named host and port.
- connectToEngineReceiveOnly(String, int, String) - Static method in class com.apama.engine.EngineManagementFactory
-
Attempt to establish a receive-only connection to an Engine listening
on the named host and port.
- connectToServer(String, int) - Static method in class com.apama.net.interfaces.PingableClientFactory
-
This static method attempts to establish a connection to a
Server using TCP/HTTP.
- ConsumerOperationsInterface - Interface in com.apama.engine.beans.interfaces
-
ConsumerOperationsInterface is an interface that specifies the standard operations
to enable a client to receive events on specific channels from a remote Correlator.
- containsKey(String) - Method in class com.apama.correlator.memstore.AbstractTable
-
Returns true if this map contains a mapping for the specified
key.
- containsKey(String) - Method in class com.apama.correlator.memstore.ConcurrentMapAdapter
-
- containsKey(Object) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Returns true if this map contains a mapping for the
specified name.
- containsKey(Object) - Method in class com.apama.util.TimestampSet
-
Returns true if this map contains the specified key
- containsValidationFailureMessages() - Method in exception com.apama.services.scenario.InvalidInputParameterException
-
Determine if this exception contains any validation failure messages for
individual input parameters.
- containsValue(Object) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Returns true if this map maps one or more names to the
specified value.
- containsValue(Object) - Method in class com.apama.util.TimestampSet
-
Returns true if this map maps one or more names to the
specified time.
- 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
- Context - Class in com.apama.jmon
-
The Context class provides a Java representation of the MonitorScript context type.
- Context() - Constructor for class com.apama.jmon.Context
-
The default constructor.
- Context(Context) - Constructor for class com.apama.jmon.Context
-
A copy constructor
- COPYRIGHT - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
The copyright statement that is displayed in the usage string of a number of components.
- Correlator - Class in com.apama.epl.plugin
-
Static class to allow java plugins to interact with the correlator.
- Correlator - Class in com.apama.jmon
-
This class provides various utility methods related to the Apama Event
Correlator, that can be invoked from within JMon applications.
- createCommandDescriptor(String) - Static method in class com.apama.dashboard.command.CommandDescriptorFactory
-
Create a new instance of ICommandDescriptor.
- createEngineClient() - Static method in class com.apama.engine.beans.EngineClientFactory
-
Create a new EngineClientInterface instance that enables a client process to connect to an engine to
send/receive events or perform management operations such as inject and delete.
- createEngineClient(String, int, String) - Static method in class com.apama.engine.beans.EngineClientFactory
-
Create a new EngineClientInterface instance that enables a client process to connect to an engine to
send/receive events or perform management operations such as inject and delete.
- createEventService() - Static method in class com.apama.services.event.EventServiceFactory
-
Create a new instance of the EventService with default parameters.
- createEventService(String, int) - Static method in class com.apama.services.event.EventServiceFactory
-
Create a new EventService instance with
an EngineClient connected to a Correlator on the given host and port.
- createEventService(String, int, String) - Static method in class com.apama.services.event.EventServiceFactory
-
Create a new EventService instance with
an EngineClient connected to a Correlator on the given host and port, with a specified process name.
- createEventService(EngineClientInterface) - Static method in class com.apama.services.event.EventServiceFactory
-
Create a new EventService instance using
the supplied EngineClient to connect to a Correlator.
- createFunctionDescriptor(String, String[], String[], int, String[], String) - Static method in class com.apama.dashboard.function.FunctionDescriptorFactory
-
Create a new IFunctionDescriptor.
- createGenericComponentManagement(String, int) - Static method in class com.apama.net.interfaces.GenericComponentManagementFactory
-
Creates an instance implementing GenericComponentManagement.
- createInstance(String) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Create a new instance of this scenario, using default values for all input paramters.
- createInstance(String, Map<String, Object>) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Create a new instance of this scenario, with the supplied values for input paramters.
- createInstance(String, Map<String, Object>, PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Create a new instance of this Scenario, with the supplied values for input paramters, and atomically add a listener.
- createInstance(String, Map<String, Object>, String, PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Create a new instance of this Scenario, with the supplied values for input paramters, and atomically add a listener.
- createJmsReceiverMapper() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsReceiverMapperFactory
-
Factory method for creating a mapper that will be used by a single thread.
- createJmsReceiverMapper() - Method in class com.apama.correlator.jms.config.api.mapper.SimpleAbstractJmsMessageMapper
-
Provides a trivial implementation of this factory method.
- createJmsSenderMapper() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsSenderMapperFactory
-
Factory method for creating a mapper that will be used by a single thread.
- createJmsSenderMapper() - Method in class com.apama.correlator.jms.config.api.mapper.SimpleAbstractJmsMessageMapper
-
Provides a trivial implementation of this factory method.
- createRowValue() - Method in class com.apama.correlator.memstore.RowValueHelper
-
Create a new RowValue instance, with its data structured pre-allocated for
the field types of this schema.
- createScenarioService(String, int, Map<String, Object>, PropertyChangeListener) - Static method in class com.apama.services.scenario.ScenarioServiceFactory
-
Create a new ScenarioService instance with an EngineClient connected to
a Correlator on the given host and port, and optionally pass a listener that will be
added before any events are received.
- createScenarioService(String, int, String, Map<String, Object>, PropertyChangeListener) - Static method in class com.apama.services.scenario.ScenarioServiceFactory
-
Create a new ScenarioService instance with an EngineClient connected to
a Correlator on the given host and port, and optionally pass a listener that will be
added before any events are received.
- createScenarioService(EngineClientInterface, Map<String, Object>, PropertyChangeListener) - Static method in class com.apama.services.scenario.ScenarioServiceFactory
-
Create a new ScenarioService instance using the supplied EngineClient to
connect to a Correlator, and optionally pass a listener that will be
added before any events are received.
- createScenarioService(IEventService, Map<String, Object>, PropertyChangeListener) - Static method in class com.apama.services.scenario.ScenarioServiceFactory
-
Create a new ScenarioService instance using the supplied IEventService to
connect to a Correlator, and optionally pass a listener that will be
added before any events are received.
- createStore() - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
Prepares and returns a new store object using this factory's configuration and storeName.
- createTable(String, String[], String[]) - Method in class com.apama.correlator.memstore.AbstractStore
-
Creates a new table instance.
- createTabularData() - Static method in class com.apama.dashboard.data.TabularDataFactory
-
Create a new instance of ITabularData.
- crit(String) - Method in class com.apama.util.Logger
-
Logs the specified message at CRIT level.
- crit(String, Throwable) - Method in class com.apama.util.Logger
-
Logs the specified message at CRIT level, followed by a stack trace for the exception.
- CRIT_STR - Static variable in class com.apama.util.Logger
-
- critEnabled() - Method in class com.apama.util.Logger
-
Determines if the logging is enabled at the CRIT level for this Logger instance.
- DashboardManager - Class in com.apama.dashboard
-
DashboardManager is a class that provides static methods for getting
the IDashboardContext for use in a custom function or command.
- DashboardManager() - Constructor for class com.apama.dashboard.DashboardManager
-
- DATA_FIELD - Static variable in interface com.apama.iaf.plugin.ConfigurableCodec
-
- debug(String) - Method in class com.apama.util.Logger
-
Logs the specified message at DEBUG level.
- debug(String, Throwable) - Method in class com.apama.util.Logger
-
Logs the specified message at DEBUG level, followed by a stack trace for the exception.
- DEBUG_STR - Static variable in class com.apama.util.Logger
-
- debugEnabled() - Method in class com.apama.util.Logger
-
Determines if the logging is enabled at the DEBUG level for this Logger instance.
- DECIMAL - Static variable in class com.apama.event.parser.FieldTypes
-
Get the singleton field type object for the Apama
decimal type,
for which values are specified as Java
DecimalFieldValue
objects.
- DecimalFieldType - Class in com.apama.event.parser
-
Represents the Apama
decimal
type,
for which values are specified as
DecimalFieldValue
objects.
- DecimalFieldValue - Class in com.apama.event.parser
-
Represents the value of an Apama decimal field.
- DecimalFieldValue(String) - Constructor for class com.apama.event.parser.DecimalFieldValue
-
Create a new DecimalFieldValue from a String value
- DecimalFieldValue(BigDecimal) - Constructor for class com.apama.event.parser.DecimalFieldValue
-
Create a new DecimalFieldValue from a BigDecimal
- decodeString(String, ParameterTypeEnum) - Static method in enum com.apama.services.scenario.ParameterTypeEnum
-
Utility method to convert the EPL string representation of a parameter value to a Java object, based on its type identifier.
- DECODINGFAILURE - Static variable in exception com.apama.iaf.plugin.CodecException
-
Couldn't decode an incoming customer event
- DECODINGFAILURE - Static variable in exception com.apama.iaf.plugin.TransportException
-
Trouble sending transport event to decoder
- deepPing() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
Ask the remote server to perform a 'deep ping' operation.
- deepPing() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Perform a component-specific 'deep' ping
- deepPing() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Perform a component-specific 'deep' ping
- DEFAULT_ACKDATA_TIMEOUT - Static variable in interface com.apama.services.scenario.IScenarioService
-
Default value for the configuration property that specifies the timeout
for waiting for an operation response after the acknowledge (60000ms).
- DEFAULT_ADAPTER_PORT - Static variable in interface com.apama.net.ConnectionConstants
-
The default port number for connecting to an Adapter (16903).
- DEFAULT_AUTO_INSTANCE_DISCOVERY - Static variable in interface com.apama.services.scenario.IScenarioService
-
Default value for automatic instance discovery (true)
- DEFAULT_CONNECTION_POLLING_INTERVAL - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
The default value for the connectionPollingInterval property in milliseconds.
- DEFAULT_DISCONNECT_IF_SLOW - Static variable in interface com.apama.services.scenario.IScenarioService
-
Default value for the boolean flag specifying if we should be disconnected if
slow (false)
- DEFAULT_ENFORCE_RESPONSE_SEQUENCING - Static variable in interface com.apama.services.event.IEventServiceChannel
-
Default value for the flag specifying if strict response sequencing should be used (true).
- DEFAULT_ENGINE_PORT - Static variable in interface com.apama.net.ConnectionConstants
-
The default port number for connecting to a Correlator (15903).
- DEFAULT_HOST - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
- DEFAULT_HOST - Static variable in interface com.apama.net.ConnectionConstants
-
The default host name for connecting to a Server (localhost).
- DEFAULT_INBOUND_EVENT_QUEUE_SOFT_REFERENCE_PREFIXES - Static variable in interface com.apama.services.event.IEventServiceChannel
-
Default value for the set of event name prefixes that would cause a received
event to be placed in the inbound event queue as a SoftReference (null).
- DEFAULT_INSPECT_POLLING_INTERVAL - Static variable in interface com.apama.engine.beans.interfaces.InspectOperationsInterface
-
The default value for the inspectPollingInterval property.
- DEFAULT_LOG_FILENAME - Static variable in class com.apama.util.Logger
-
The default log filename is null, which will cause stdout/err to be used instead.
- DEFAULT_LOG_IMPL - Static variable in class com.apama.util.Logger
-
- DEFAULT_LOG_INCREMENTAL_TIME - Static variable in class com.apama.util.Logger
-
The default value for the system property indicating if the Logger
implementation named "simple" will log the time since the last log statement
- useful to set to true occasionally when diagnosing performance issues.
- DEFAULT_LOG_LEVEL - Static variable in class com.apama.util.Logger
-
- DEFAULT_LOG_RELATIVE_TIME - Static variable in class com.apama.util.Logger
-
The default value for the system property indicating if the Logger
implementation named "simple" will log the number of seconds since
the logger was first used
- currently "false" for backwards compatibility of log file format, but
may change to "true" in a future release.
- DEFAULT_LOG_THREADNAME - Static variable in class com.apama.util.Logger
-
The default value for the system property indicating if the Logger
implementation named "simple" will log the name of the calling thread
- currently "false" for backwards compatibility of log file format, but
may change to "true" in a future release.
- DEFAULT_LOG_TIME - Static variable in class com.apama.util.Logger
-
The default value for the system property indicating if the Logger
implementation named "simple" will log the current date/time
- currently "false" for backwards compatibility of log file format, but
may change to "true" in a future release.
- DEFAULT_MESSAGEID_FIELD_NAME - Static variable in interface com.apama.services.event.IEventServiceChannel
-
Default value for the field name of message ID's for request-response ("messageId").
- DEFAULT_MONITOR_ONLY - Static variable in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
The default value for the monitorOnly property.
- DEFAULT_PORT - Static variable in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
The default value for the port property.
- DEFAULT_PORT - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
- DEFAULT_PORT - Static variable in interface com.apama.net.ConnectionConstants
-
This is an alias for DEFAULT_ENGINE_PORT.
- DEFAULT_PROCESS_NAME - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
- DEFAULT_PROCESS_NAME - Static variable in interface com.apama.net.ConnectionConstants
-
This is an alias for DEFAULT_ENGINE_PORT.
- DEFAULT_RECEIVE_ONLY - Static variable in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
The default value for the receiveOnly property.
- DEFAULT_RECONNECT_PERIOD - Static variable in interface com.apama.services.scenario.IScenarioService
-
Default value for the reconnect period (0.0, meaning no time between reconnects)
- DEFAULT_REQUEST_RESPONSE_TIMEOUT_MS - Static variable in interface com.apama.services.event.IEventServiceChannel
-
Default value for the request-reponse timeout (3000ms).
- DEFAULT_SCENARIO_EXCLUSION_FILTER - Static variable in interface com.apama.services.scenario.IScenarioService
-
Default value for the configuration property that specifies the optional
scenario exclusion filter set (null).
- DEFAULT_SCENARIO_INCLUSION_FILTER - Static variable in interface com.apama.services.scenario.IScenarioService
-
Default value for the configuration property that specifies the optional
scenario inclusion filter set (null).
- DEFAULT_SENTINEL_PORT - Static variable in interface com.apama.net.ConnectionConstants
-
The default port number for connecting to a Sentinel Agent (17903).
- DEFAULT_STATUS_POLLING_INTERVAL - Static variable in interface com.apama.engine.beans.interfaces.WatchOperationsInterface
-
The default value for the statusPollingInterval property.
- DEFAULT_STRONG_DATA_INBOUND_EVENT_QUEUE - Static variable in interface com.apama.services.scenario.IScenarioService
-
Default value for the boolean flag specifying if the inbound event queues for 'Data'
channels will use strong references (true).
- DEFAULT_USE_RAW_DATA_CHANNEL - Static variable in interface com.apama.services.scenario.IScenarioService
-
Default value for the boolean flag specifying if the 'Data' channel to subscribe
to for a scenario will be the normal (possibly throttled) channel, or the
'Raw' (always unthrottled) channel (false).
- DefaultRowKeyValueConverter<K,V> - Class in com.apama.correlator.memstore
-
Helper class for implementing RowKeyValueConverter using String for the keys and RowValue for the values.
- DefaultRowKeyValueConverter() - Constructor for class com.apama.correlator.memstore.DefaultRowKeyValueConverter
-
- delete() - Method in interface com.apama.services.scenario.IScenarioInstance
-
Delete this instance.
- deleteAll() - Method in class com.apama.engine.beans.EngineClientBean
-
Deletes everything from the engine.
- deleteAll() - Method in interface com.apama.engine.beans.interfaces.DeleteOperationsInterface
-
Deletes everything from the engine.
- deleteAll() - Method in interface com.apama.engine.EngineManagement
-
Deletes everything from the engine.
- deleteName(String, boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Delete a name from the engine.
- deleteName(String, boolean) - Method in interface com.apama.engine.beans.interfaces.DeleteOperationsInterface
-
Delete a name from the engine.
- deleteName(String) - Method in interface com.apama.engine.EngineManagement
-
Delete a named object from the Engine.
- deleteNames(List<String>, boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Delete a number of names.
- deleteNames(List<String>, boolean) - Method in interface com.apama.engine.beans.interfaces.DeleteOperationsInterface
-
Delete a number of names.
- deleteNamesFromFile(List<String>, boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Delete a number of names from a file or stdin.
- deleteNamesFromFile(List<String>, boolean, boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
- deleteNamesFromFile(List<String>, boolean) - Method in interface com.apama.engine.beans.interfaces.DeleteOperationsInterface
-
Delete a number of names from a file or stdin.
- deleteNamesFromFile(List<String>, boolean, boolean) - Method in interface com.apama.engine.beans.interfaces.DeleteOperationsInterface
-
Delete a number of names from a file or stdin.
- DeleteOperationsInterface - Interface in com.apama.engine.beans.interfaces
-
DeleteOperationsInterface is an interface that specifies the standard operations to
enable an engine client to remove items from a remote correlator.
- deregister(EngineClientInterface) - Method in interface com.apama.engine.beans.interfaces.ReconnectPolicyInterface
-
notification that this policy is no longer used to determine when to connect.
- deregisterEventType(EventType) - Method in class com.apama.event.parser.EventParser
-
Deregister the given event type from being a valid type this parser.
- destinationToString(Destination) - Method in interface com.apama.correlator.jms.config.api.mapper.JmsReceiverMapperContext
-
- destroy() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsReceiverMapper
-
Disposes of any background threads, caches or other resources created by this
mapper instance.
- destroy() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsSenderMapper
-
Disposes of any background threads, caches or other resources created by this
mapper instance.
- destroy() - Method in class com.apama.correlator.jms.config.api.mapper.SimpleAbstractJmsMessageMapper
-
Provides a trivial no-op implementation of this method.
- destroy() - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
Performs final cleanup of the Called once during clean Correlator shutdown.
- destroy() - Method in interface com.apama.services.event.IEventService
-
- destroy() - Method in interface com.apama.services.scenario.IScenarioService
-
- detachAsConsumerOfEngine(EngineClientBean, String[]) - Method in class com.apama.engine.beans.EngineClientBean
-
- detachAsConsumerOfEngine(EngineClientBean, String[], ConnectMode) - Method in class com.apama.engine.beans.EngineClientBean
-
- detachAsConsumerOfEngine(String, int, String[]) - Method in class com.apama.engine.beans.EngineClientBean
-
- detachAsConsumerOfEngine(String, int, String[], ConnectMode) - Method in class com.apama.engine.beans.EngineClientBean
-
- detachAsConsumerOfEngine(EngineClientBean, String[]) - Method in interface com.apama.engine.beans.interfaces.ConnectOperationsInterface
-
Disconnect this engine from another so that it not longer receives events
emitted on the specified channels.
- detachAsConsumerOfEngine(EngineClientBean, String[], ConnectMode) - Method in interface com.apama.engine.beans.interfaces.ConnectOperationsInterface
-
Disconnect this engine from another so that it not longer receives events
emitted on the specified channels.
- detachAsConsumerOfEngine(String, int, String[]) - Method in interface com.apama.engine.beans.interfaces.ConnectOperationsInterface
-
Disconnect this engine from another so that it not longer receives events
emitted on the specified channels.
- detachAsConsumerOfEngine(String, int, String[], ConnectMode) - Method in interface com.apama.engine.beans.interfaces.ConnectOperationsInterface
-
Disconnect this engine from another so that it not longer receives events
emitted on the specified channels.
- detachAsEventConsumerFrom(EngineManagement, String[]) - Method in interface com.apama.engine.EngineManagement
-
Detach another Engine from this one as an event supplier, with this
engine no longer consuming its events.
- detachAsEventConsumerFrom(EngineManagement, String[], ConnectMode) - Method in interface com.apama.engine.EngineManagement
-
Detach another Engine from this one as an event supplier, with this
engine no longer consuming its events.
- detachAsEventConsumerFrom(String, int, String[]) - Method in interface com.apama.engine.EngineManagement
-
Detach another Engine from this one as an event supplier, with this
engine no longer consuming its events.
- detachAsEventConsumerFrom(String, int, String[], ConnectMode) - Method in interface com.apama.engine.EngineManagement
-
Detach another Engine from this one as an event supplier, with this
engine no longer consuming its events.
- dictionary(FieldType<K>, FieldType<V>) - Static method in class com.apama.event.parser.FieldTypes
-
Create a new field type object for an Apama dictionary event field,
for which values are specified by objects implementing java.util.Map<K,V>
.
- DictionaryFieldType<K,V> - Class in com.apama.event.parser
-
Represents the Apama dictionary<key,item>
type,
for which values are specified as Map
objects.
- DictionaryFieldType(FieldType<K>, FieldType<V>) - Constructor for class com.apama.event.parser.DictionaryFieldType
-
Construct a new field type representing a dictionary whose keys are values are of specified field types.
- DirectoryProcessor - Class in com.apama.jmon.annotation
-
Process a directory tree of class files to automatically generate the JMon application deployment descriptor.
- disconnect() - Method in class com.apama.engine.beans.EngineClientBean
-
Sets the desired state of the bean to disconnected instead of connected, disconnects consumers and
stops pinging the remote correlator to keep the connection alive.
- disconnect() - Method in interface com.apama.engine.EngineManagement
-
Disconnect this client completely from the remote component.
- disconnect(String) - Method in interface com.apama.event.DisconnectableEventConsumer
-
- disconnect() - Method in interface com.apama.event.EventSupplier
-
Disconnect the EventSupplier from its consumer and
release its resources.
- disconnect(boolean) - Method in interface com.apama.event.EventSupplier
-
Disconnect the EventSupplier from its consumer and
release its resources.
- disconnect() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Disconnect from a remote server.
- disconnect() - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Disconnect from a server.
- disconnect() - Method in class com.apama.net.beans.PingBean
-
Disconnect from an server.
- DisconnectableEventConsumer - Interface in com.apama.event
-
- disconnectIfSlow() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentReceiver
-
- disconnectReceiverByComponentId(ComponentIDTuple, String) - Method in class com.apama.net.beans.GenericComponentManagementBean
-
Disconnect the receiver connected to this component that has component ID
id.
- disconnectReceiverByComponentId(ComponentIDTuple, String) - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Disconnect the receiver connected to this component that has component ID
id.
- disconnectSenderByComponentId(ComponentIDTuple, String) - Method in class com.apama.net.beans.GenericComponentManagementBean
-
Disconnect the sender connected to this component that has component ID
id.
- disconnectSenderByComponentId(ComponentIDTuple, String) - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Disconnect the sender connected to this component that has component ID
id.
- DiscoveryStatusEnum - Enum in com.apama.services.scenario
-
Enum to represent the discovery status within the Scenario Service.
- dispose() - Method in class com.apama.engine.beans.EngineClientBean
-
- dispose() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
- dispose() - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Disconnects the client and also waits to ensure that all background threads and other resources
associated with this object have been terminated or freed.
- dispose() - Method in class com.apama.net.beans.PingBean
-
- dispose() - Method in interface com.apama.services.event.IEventService
-
Disconnects this service from the Correlator and stops background threads.
- dispose() - Method in interface com.apama.services.scenario.IScenarioService
-
Dispose this service and clean up resources.
- DistMemStoreProviderException - Exception in com.apama.correlator.memstore
-
Represents a distributed MemoryStore error that is not a programming bug -
i.e either a runtime/deployment problem reported by the 3rd party library (e.g networking problem etc) or
problem with the configuration specified by the user.
- DistMemStoreProviderException(String) - Constructor for exception com.apama.correlator.memstore.DistMemStoreProviderException
-
- DistMemStoreProviderException(Throwable) - Constructor for exception com.apama.correlator.memstore.DistMemStoreProviderException
-
- DistMemStoreProviderException(String, Throwable) - Constructor for exception com.apama.correlator.memstore.DistMemStoreProviderException
-
- doRequest(String) - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- doRequest(String) - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Execute a component-specific command
- doRequest(String) - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Execute a component-specific command
- ELMappingExtensionManager - Interface in com.apama.adapters.el.api
-
Allows registration of EL methods and resolvers to the mapping layer.
- ELMappingExtensionProvider - Interface in com.apama.adapters.el.api
-
Interface for registering EL methods and resolvers.
- emit() - Method in class com.apama.jmon.Event
-
Emit this Event from the Engine on the default channel.
- emit(String) - Method in class com.apama.jmon.Event
-
Emit this Event from the Engine on a specific channel.
- empty() - Method in class com.apama.epl.plugin.Channel
-
Returns true iff this wraps an empty context i.e.
- empty() - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Check whether the event is empty or not.
- ENCODINGFAILURE - Static variable in exception com.apama.iaf.plugin.CodecException
-
Couldn't encode an incoming normalised event
- EngineClientBean - Class in com.apama.engine.beans
-
EngineClientBean is a JavaBean for interacting with an Apama engine, typically a Correlator.
- EngineClientBean() - Constructor for class com.apama.engine.beans.EngineClientBean
-
Default constructor - as required to be a bean.
- EngineClientFactory - Class in com.apama.engine.beans
-
EngineClientFactory is a factory for classes that implement Apama messaging or correlator management interfaces.
- EngineClientInterface - Interface in com.apama.engine.beans.interfaces
-
EngineClientInterface is an interface that specifies ALL of the standard operations to
enable an engine client to communicate with a remote correlator.
- EngineConnection - Class in com.apama.engine
-
EngineConnection encapsulates the information related to a connection
between two Apama messaging components.
- EngineConnection(String, int, String...) - Constructor for class com.apama.engine.EngineConnection
-
- EngineException - Exception in com.apama
-
An EngineException is thrown by various methods of classes in the
Engine Client SDK if any problems are encountered.
- EngineException(String, String[]) - Constructor for exception com.apama.EngineException
-
Create a simple exception with the given message.
- EngineException(String) - Constructor for exception com.apama.EngineException
-
Create a simple exception with the given message.
- EngineException(Throwable) - Constructor for exception com.apama.EngineException
-
Create a compound exception that references the given exception.
- EngineException(String, Throwable) - Constructor for exception com.apama.EngineException
-
Create a compound exception with the given message and that references the given exception.
- EngineInfo - Interface in com.apama.engine
-
This interface represents the API for accessing all of the information returned
from an engine as result of a call to the engineInspect() method.
- EngineManagement - Interface in com.apama.engine
-
The EngineManagement interface is the primary low-level interface to the Engine,
and allows operations to be carried out on it.
- EngineManagementFactory - Class in com.apama.engine
-
This class is used to create objects that implement the EngineManagement
interface.
- EngineStatus - Interface in com.apama.engine
-
EngineStatus represents the operational status of the Engine.
- enqueue(String) - Static method in class com.apama.epl.plugin.Correlator
-
Enqueues the supplied string to all public contexts.
- enqueue(String) - Static method in class com.apama.jmon.Correlator
-
Enqueue the stringified form of an event for processing.
- enqueue() - Method in class com.apama.jmon.Event
-
Enqueue this Event internally within the Correlator.
- enqueueTo(String, Context) - Static method in class com.apama.epl.plugin.Correlator
-
Enqueues the supplied string to the specified context.
- enqueueTo(Context) - Method in class com.apama.jmon.Event
-
Enqueue this event to a correlator context.
- enqueueTo(Context[]) - Method in class com.apama.jmon.Event
-
Enqueue this event to an array of correlator contexts.
- enqueueTo(List<Context>) - Method in class com.apama.jmon.Event
-
Enqueue this event to a list of correlator contexts.
- entrySet() - Method in class com.apama.iaf.plugin.NormalisedEvent
-
- entrySet() - Method in class com.apama.util.TimestampSet
-
- EPLPlugin - Annotation Type in com.apama.epl.plugin.annotation
-
This Annotation is used to mark a Java EPL Plugin class.
- equals(Object) - Method in class com.apama.correlator.memstore.RowValue
-
- 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.apama.event.parser.EventType
-
equals if both objects has same field names/types
- equals(Object) - Method in class com.apama.iaf.plugin.EventCodecProperty
-
Returns true if the specified object is a EventCodecProperty with a
matching key, whatever its value.
- equals(Object) - Method in class com.apama.iaf.plugin.EventTransportProperty
-
Returns true if the specified object is a EventTransportProperty with a
matching key, whatever its value.
- equals(Object) - Method in class com.apama.jmon.Context
-
- equals(Object) - Method in class com.apama.jmon.Event
-
Override Object.equals() to check equality based upon
the field values of the instance.
- equals(Object) - Method in class com.apama.jmon.Location
-
- error(String) - Method in class com.apama.util.Logger
-
Logs the specified message at ERROR level.
- error(String, Throwable) - Method in class com.apama.util.Logger
-
Logs the specified message at ERROR level, followed by a stack trace for the exception.
- ERROR_STR - Static variable in class com.apama.util.Logger
-
- errorEnabled() - Method in class com.apama.util.Logger
-
Determines if the logging is enabled at the ERROR level for this Logger instance.
- errorWithDebugStackTrace(String, Throwable) - Method in class com.apama.util.Logger
-
Logs the specified message at ERROR level followed by the exception's message string, and then
logs the exception's stack trace at DEBUG level.
- evaluateFunction(String, IVariableData) - Method in interface com.apama.dashboard.function.IFunctionLibrary
-
Invoke a function.
- Event - Class in com.apama.event
-
An Event object representing an event instance in flat event string format and/or
structured format (as defined by its associated
EventType
).
- Event(String, String) - Constructor for class com.apama.event.Event
-
Constructor to create an Event based on a raw event string and channel string (for advanced uses only).
- Event(String) - Constructor for class com.apama.event.Event
-
Constructor to create an Event based on a raw event string (for advanced uses only).
- Event(EventType) - Constructor for class com.apama.event.Event
-
Constructor to create an Event based on an EventType.
- Event - Class in com.apama.jmon
-
Abstract base class for a Java object that will be treated as an Apama event
inside the Correlator, with a public Java field for each field of the event.
- EventCodec - Interface in com.apama.iaf.plugin
-
EventCodec defines the interface that Java IAF codecs implement so they
can be used by the IAF to convert a downstream event from the transport
into the normalised form required by the Semantic Mapper.
- EventCodecProperty - Class in com.apama.iaf.plugin
-
EventCodecProperty holds a (name, value) pair of strings, and is used
to store codec configuration propery values.
- EventCodecProperty(String, String) - Constructor for class com.apama.iaf.plugin.EventCodecProperty
-
Constructs a new (immutable) EventCodecProperty to represent the
specified (name, value) pair.
- EventConsumer - Interface in com.apama.event
-
An EventConsumer can connect to the Engine through an
EventSupplier and register to receive events.
- EventDecoder - Interface in com.apama.iaf.plugin
-
EventDecoder defines the interface that Java IAF decoders implement so they
can be used by the IAF to convert a downstream event from the transport
into the normalised form required by the Semantic Mapper.
- EventExpression - Class in com.apama.jmon
-
Instances of this class are declared to represent an "Event Expression" as
defined in the Apama reference manual "The JMON Application Framework".
- EventExpression(String) - Constructor for class com.apama.jmon.EventExpression
-
Constructor to create a new instance with the given immutable expression string.
- EventFieldAttributes - Class in com.apama.jmon
-
Deprecated.
This class has been deprecated and may be removed in a future release -
Please use the new JMon annotations instead.
- EventHandler - Interface in com.apama.epl.plugin
-
Handler interface used for callbacks when a plugin listens for events on a channel.
- EventListenerAdapter - Class in com.apama.event
-
EventListenerAdapter is a class that provides a skeletal implementation of
the IEventListener interface to minimize effort required to implement the
interface.
- EventListenerAdapter() - Constructor for class com.apama.event.EventListenerAdapter
-
- EventParser - Class in com.apama.event.parser
-
Provides the functionality to parse
String
objects into Apama
Event
objects, for
any
EventType
registered with the parser.
- EventParser(EventType...) - Constructor for class com.apama.event.parser.EventParser
-
Constructor to create an EventParser.
- EventReader - Class in com.apama.event
-
Utility class to read
Event
objects from a text stream in event file format
(individually, or in batches with optional timestamps if the BATCH keyword
is used in the input stream).
- EventReader(BufferedReader, String) - Constructor for class com.apama.event.EventReader
-
Constructor.
- EventServiceException - Exception in com.apama.services.event
-
EventServiceException is a base exception class for all other specialized
exceptions within with the Event Service.
- EventServiceException(String) - Constructor for exception com.apama.services.event.EventServiceException
-
- EventServiceException(String, Throwable) - Constructor for exception com.apama.services.event.EventServiceException
-
- EventServiceException(Throwable) - Constructor for exception com.apama.services.event.EventServiceException
-
- EventServiceFactory - Class in com.apama.services.event
-
EventServiceFactory is a class that provides a factory for creating new
instances of classes that implement the IEventService interface.
- EventSupplier - Interface in com.apama.event
-
An EventSupplier represents the resources created by the Engine
to service a connection to an external sink of events.
- EventTransport - Interface in com.apama.iaf.plugin
-
EventTransport defines the interface that Java IAF transports implement so
they can be used by the IAF to send an upstream event that has passed
through the Semantic Mapper and encoder.
- EventTransportProperty - Class in com.apama.iaf.plugin
-
EventTransportProperty holds a (name, value) pair of strings, and is used
to store transport configuration propery values.
- EventTransportProperty(String, String) - Constructor for class com.apama.iaf.plugin.EventTransportProperty
-
Constructs a new (immutable) EventTransportProperty to represent the
specified (name, value) pair.
- EventType - Class in com.apama.event.parser
-
Represents the definition of an Apama event type,
for which values are specified as
Event
objects.
- EventType(String, Field<?>...) - Constructor for class com.apama.event.parser.EventType
-
Create a new Event Type by specifying the name of the event and the
FieldType of each of the event parameter.
- EventType - Annotation Type in com.apama.jmon.annotation
-
This Annotation is used to mark a JMON Event class.
- exists(String) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Check whether a given element exists in the normalised event.
- expand(double) - Method in class com.apama.jmon.Location
-
Returns a new Location with the dimensions of this Location expanded by
the given distance in each direction (4 directions).
- ExtendedCodecStatus - Class in com.apama.iaf.plugin
-
ExtendedCodecStatus contains status information about the codec, and is
returned by AbstractCodecEvent.getStatus().
- ExtendedCodecStatus(String, long, long, Properties) - Constructor for class com.apama.iaf.plugin.ExtendedCodecStatus
-
Constructs a ExtendedCodecStatus instance with the specified parameters.
- ExtendedTransportStatus - Class in com.apama.iaf.plugin
-
ExtendedTransportStatus contains status information about the transport, and is
returned by AbstractTransportEvent.getStatus().
- ExtendedTransportStatus(String, long, long, Properties) - Constructor for class com.apama.iaf.plugin.ExtendedTransportStatus
-
Constructs a ExtendedTransportStatus instance with the specified parameters.
- GenericComponentLogLevelNames - Static variable in interface com.apama.net.interfaces.GenericComponentManagement
-
- GenericComponentManagement - Interface in com.apama.net.interfaces
-
Generic management interface for Apama components.
- GenericComponentManagement.GenericComponentConnection - Interface in com.apama.net.interfaces
-
The interface describing a messaging connection to a component
- GenericComponentManagement.GenericComponentConnectionSet - Interface in com.apama.net.interfaces
-
- GenericComponentManagement.GenericComponentInfo - Interface in com.apama.net.interfaces
-
A set of related component info tuples
- GenericComponentManagement.GenericComponentInfoTuple - Interface in com.apama.net.interfaces
-
A name-value pair holding some information about a component
- GenericComponentManagement.GenericComponentLogLevel - Enum in com.apama.net.interfaces
-
Log verbosity levels
- GenericComponentManagement.GenericComponentReceiver - Interface in com.apama.net.interfaces
-
The interface describing a messaging receiver connected to a component
- GenericComponentManagement.GenericComponentSender - Interface in com.apama.net.interfaces
-
The interface describing a messaging sender connected to a component
- GenericComponentManagementBean - Class in com.apama.net.beans
-
GenericComponentManagementBean is a JavaBean that provides a way of
controlling an arbitrary server that exports a GenericComponentManagement
interface.
- GenericComponentManagementBean() - Constructor for class com.apama.net.beans.GenericComponentManagementBean
-
Default constructor - as required to be a bean.
- GenericComponentManagementBean(String, int, String) - Constructor for class com.apama.net.beans.GenericComponentManagementBean
-
Full argument constructor.
- GenericComponentManagementException - Exception in com.apama.net.interfaces
-
Base for all exceptions thrown by the GenericComponentManagement interface.
- GenericComponentManagementException(String) - Constructor for exception com.apama.net.interfaces.GenericComponentManagementException
-
- GenericComponentManagementException(Throwable) - Constructor for exception com.apama.net.interfaces.GenericComponentManagementException
-
- GenericComponentManagementException(String, Throwable) - Constructor for exception com.apama.net.interfaces.GenericComponentManagementException
-
- GenericComponentManagementFactory - Class in com.apama.net.interfaces
-
Create objects that implement the GenericComponentManagement interface.
- GenericComponentManagementOperationsInterface - Interface in com.apama.net.beans.interfaces
-
- get(String) - Method in class com.apama.correlator.memstore.AbstractTable
-
Returns the value to which the specified key is mapped,
or null
if this map contains no mapping for the key.
- get(String) - Method in class com.apama.correlator.memstore.ConcurrentMapAdapter
-
- get(Object) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Returns the value to which the specified name is mapped, or
null if the map contains no mapping for this key.
- get(Object) - Method in class com.apama.util.TimestampSet
-
Returns the time to which the specified name is mapped, or
null if the map contains no mapping for this index.
- getAddress() - Method in interface com.apama.engine.NamedReceiverInfo
-
Get the address from which this Receiver is connected
- getAggregates() - Method in interface com.apama.engine.EngineInfo
-
Get information for the set of aggregate functions that are/were live in the engine
at the point of inspection.
- getAllConsumers() - Method in class com.apama.engine.beans.EngineClientBean
-
Get all existing uniquely-named consumers.
- getAllConsumers() - Method in interface com.apama.engine.beans.interfaces.ReceiveConsumerOperationsInterface
-
Get all existing uniquely-named consumers.
- getAllValues() - Method in interface com.apama.engine.EngineStatus
-
Get the map of all status items
- getAPIVersion() - Method in class com.apama.iaf.plugin.AbstractEventCodec
-
Return the codec API version that the codec was built against.
- getAPIVersion() - Method in class com.apama.iaf.plugin.AbstractEventTransport
-
Return the transport API version that the transport was built against.
- getArgNames() - Method in interface com.apama.dashboard.function.IFunctionDescriptor
-
Get the argument names to the function.
- getArgVarNames() - Method in interface com.apama.dashboard.function.IFunctionDescriptor
-
Get the array of variable names to hold argument values.
- getBackupCopies() - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
Retrieve the number of additional redundant nodes that will hold a backup copy of data.
- getBeanConnected() - Method in class com.apama.engine.beans.EngineClientBean
-
Get the beanConnected property value.
- getBeanConnected() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Get the beanConnected property value.
- getBeanConnected() - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Get the beanConnected property value.
- getBeanConnected() - Method in class com.apama.net.beans.PingBean
-
Get the beanConnected property value.
- getBoolean(int) - Method in class com.apama.correlator.memstore.RowValue
-
Get the n'th field of this type.
- getBooleanCellValue(int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Get the value of a boolean cell in a data table.
- getBuildNumber() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getBuildNumber() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the component's build number
- getBuildNumber() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the component's build number
- getBuildPlatform() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getBuildPlatform() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the component's build platform
- getBuildPlatform() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the component's build platform
- getCapabilities() - Method in class com.apama.iaf.plugin.AbstractEventCodec
-
Return the capabilities of the codec.
- getCapabilities() - Method in class com.apama.iaf.plugin.AbstractEventTransport
-
Return the capabilities of the transport.
- getCellValue(int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Get the value of a cell in a data table.
- getChannel() - Method in class com.apama.event.Event
-
Method to retrieve the channel name for an event.
- getChannel(String) - Method in interface com.apama.services.event.IEventService
-
Get an EventServiceChannel for a given channel or channels.
- getChannels() - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Get the list of channel names to which this consumer is subscribed.
- getChannels() - Method in class com.apama.engine.EngineConnection
-
Get the channels associated with this connection.
- getChannels() - Method in interface com.apama.engine.NamedContextInfo
-
Get the channels to which this Context is subscribed
- getChannels() - Method in interface com.apama.engine.NamedPluginReceiverInfo
-
Get the channels to which this Receiver is subscribed
- getChannels() - Method in interface com.apama.engine.NamedReceiverInfo
-
Get the channels to which this Receiver is subscribed
- getChannels() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentReceiver
-
- getClusterName() - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
The provider specific clusterName which groups same named distributed stores together for communication and data sharing.
- getColumnIndex(String) - Method in interface com.apama.dashboard.data.ITabularData
-
Get the index of a column in a data table.
- getColumnNames() - Method in interface com.apama.dashboard.data.ITabularData
-
Get the names of the columns in a data table.
- getColumnTypeCodes() - Method in interface com.apama.dashboard.data.ITabularData
-
Get the types of the columns in a data table.
- getCommandDashboardContext() - Static method in class com.apama.dashboard.DashboardManager
-
Gets the dashboard context for a command.
- getCommandDescriptors() - Method in interface com.apama.dashboard.command.ICommandLibrary
-
Get the list of CommandDescriptors defining the commands implemented by the
library.
- getComponentVersion() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getComponentVersion() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the component's version number
- getComponentVersion() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the component's version number
- getConfig() - Method in interface com.apama.services.event.IEventServiceChannel
-
Get the channel configuration that define the requested operating semantics of this instance.
- getConfig() - Method in interface com.apama.services.scenario.IScenarioService
-
Get the configuration properties that define the requested operating semantics of this instance of the service.
- getConnectionId() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsReceiverMapperContext
-
- getConnectionId() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsSenderMapperContext
-
- getConnectionPollingInterval() - Method in class com.apama.engine.beans.EngineClientBean
-
Get the polling interval (in milliseconds) for the background connection and ping thread.
- getConnectionPollingInterval() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Get the polling interval (in milliseconds) for the internal connection
test thread.
- getConnectionPollingInterval() - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Get the polling interval (in milliseconds) for the internal connection test thread.
- getConnectionPollingInterval() - Method in class com.apama.net.beans.PingBean
-
Get the polling interval (in milliseconds) for the internal connection test thread.
- getConnections() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getConnections() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Request the set of messaging peers attached to the component
- getConsumer(String) - Method in class com.apama.engine.beans.EngineClientBean
-
Get an existing uniquely-named consumer.
- getConsumer(String) - Method in interface com.apama.engine.beans.interfaces.ReceiveConsumerOperationsInterface
-
Get an existing uniquely-named consumer.
- getContexts() - Method in interface com.apama.engine.EngineInfo
-
Get information for the set of Contexts that are/were live in the engine
at the point of inspection.
- getCurrent() - Static method in class com.apama.epl.plugin.Context
-
Returns a reference to the context the plugin is currently being called from.
- getCurrent() - Static method in class com.apama.jmon.Context
-
Returns a Context instance that corresponds to the current correlator context.
- getCurrentDirectory() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getCurrentDirectory() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the component's current working directory path
- getCurrentDirectory() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the component's current working directory path
- getCurrentTime() - Static method in class com.apama.jmon.Correlator
-
Get the current time from the Correlator, expressed as the number of
seconds since the epoch.
- getData() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentInfo
-
- getDataArrays() - Method in interface com.apama.dashboard.data.ITabularData
-
Get the data arrays for the data in a data table.
- getDecoded() - Method in class com.apama.iaf.plugin.CodecStatus
-
- getDefaultParser() - Static method in class com.apama.event.parser.EventParser
-
Singleton method for retrieving the default (singleton) EventParser.
- getDeliveryMode() - Method in class com.apama.correlator.jms.config.api.mapper.JmsSenderMessageHolder
-
- getDescription() - Method in interface com.apama.dashboard.function.IFunctionDescriptor
-
Get the description of function.
- getDescription() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get the description of the scenario.
- getDestination() - Method in class com.apama.correlator.jms.config.api.mapper.JmsSenderMessageHolder
-
- getDiscoveryStatus() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get the status of the internal scenario instance discovery process.
- getDiscoveryStatus() - Method in interface com.apama.services.scenario.IScenarioService
-
Get the status of the internal scenario discovery process.
- getDisplayName() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get the display name of the scenario.
- getDoubleCellValue(int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Get the value of a double cell in a data table.
- getDoubleVar(String) - Method in interface com.apama.dashboard.data.IVariableData
-
Get the value of a variable as a double.
- getElementType() - Method in class com.apama.event.parser.SequenceFieldType
-
Get the type of the elements.
- getEncoded() - Method in class com.apama.iaf.plugin.CodecStatus
-
- getEngineClient() - Method in interface com.apama.services.event.IEventService
-
Get a handle on the underlying EngineClient.
- getEngineInfo() - Method in class com.apama.engine.beans.EngineClientBean
-
Get the most recently recorded inspection information.
- getEngineInfo() - Method in interface com.apama.engine.beans.interfaces.InspectOperationsInterface
-
Get the most recently recorded inspection information.
- getEngineVersion() - Method in interface com.apama.engine.EngineManagement
-
Get the version of the Engine.
- getErrorCode() - Method in exception com.apama.iaf.plugin.CodecException
-
Returns the integer code representing the type of transport error that
occurred.
- getErrorCode() - Method in exception com.apama.iaf.plugin.SemanticMapperException
-
Returns the integer code representing the type of transport error that
occurred.
- getErrorCode() - Method in exception com.apama.iaf.plugin.TransportException
-
Returns the integer code representing the type of transport error that
occurred.
- getEvent() - Method in interface com.apama.services.event.IResponseWrapper
-
Get the wrapped Event.
- getEventExpressionString() - Method in class com.apama.jmon.EventExpression
-
Get the String value of the EventExpression.
- getEventListeners() - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Get a list of all subscribed listeners (as an array).
- getEventService() - Method in interface com.apama.services.scenario.IScenarioService
-
Get the underlying EventService that is being used by this ScenarioService.
- getEventString() - Method in class com.apama.correlator.jms.config.api.mapper.MappableApamaEvent
-
- getEventType() - Method in class com.apama.event.Event
-
Get the EventType for this Event.
- getEventType(String) - Method in class com.apama.event.parser.EventParser
-
Retrieve an Event Type by name.
- getEventTypes() - Method in interface com.apama.engine.EngineInfo
-
Get information for the set of Event Types that are/were live in the engine
at the point of inspection.
- getExtraParams() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Return the read-only map of extra parameters (reserved for future use).
- getField(String) - Method in class com.apama.event.Event
-
Get the value of a field in this event instance.
- getField(Field<T>) - Method in class com.apama.event.Event
-
Get the value of a field in this event instance.
- getField(String, FieldType<T>) - Method in class com.apama.event.Event
-
Get the value of a field in this event instance.
- getField(String) - Method in class com.apama.event.parser.EventType
-
Get a named field.
- getFieldAttributes(String) - Method in class com.apama.jmon.Event
-
Deprecated.
This method has been deprecated and may be removed in a future release -
Please use the new JMon annotations instead.
- getFieldNames() - Method in class com.apama.event.parser.EventType
-
Method to retrieve the field names as String array for the event.
- getFieldsMap() - Method in class com.apama.event.Event
-
Method to retrieve the fieldName/value map of the event fields.
- getFloat(int) - Method in class com.apama.correlator.memstore.RowValue
-
Get the n'th field of this type.
- getFloatCellValue(int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Get the value of a float cell in a data table.
- getFloatValue() - Method in class com.apama.event.parser.DecimalFieldValue
-
Get the floating point value.
- getFullyQualifiedName() - Method in interface com.apama.engine.NameInfo
-
Get the fully qualified name of the item.
- getFunctionDashboardContext(IVariableData) - Static method in class com.apama.dashboard.DashboardManager
-
Gets the dashboard context for a function.
- getFunctionDescriptors() - Method in interface com.apama.dashboard.function.IFunctionLibrary
-
Get the list of FunctionDescriptors defining the functions implemented by the
library.
- getHost() - Method in class com.apama.engine.beans.EngineClientBean
-
Get the name of the host to be connected to.
- getHost() - Method in class com.apama.engine.EngineConnection
-
Get the host associated with this connection.
- getHost() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Get the name of the host to be connected to.
- getHost() - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Get the name of the host to be connected to.
- getHost() - Method in class com.apama.net.beans.PingBean
-
Get the name of the host to be connected to.
- getHostname() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getHostname() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the hostname that component is running on
- getHostname() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the hostname that component is running on
- getId() - Method in class com.apama.epl.plugin.Context
-
Equivalent to the EPL method getId on the context type
- getId() - Method in class com.apama.jmon.Context
-
Returns a unique identifier for the context.
- getId() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get the ID of the scenario.
- getId() - Method in interface com.apama.services.scenario.IScenarioInstance
-
Get the ID of the instance.
- getInfo(String) - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getInfo(String) - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Request component-specific status/configuration information
- getInfo(String) - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Request component-specific status/configuration information
- getInitialMinClusterSize() - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
Retrieve the number of nodes required to join the cluster before the Distributed MemoryStore
will send the Finished event.
- getInputParameterConstraints() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get the constraints of all input parameters for the scenario.
- getInputParameterDefaults() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get the default values of all input parameters for the scenario.
- getInputParameterNames() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get the names of all input parameters for the scenario.
- getInputParameterTypes() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get the types of all input parameters for the scenario.
- getInspectPollingInterval() - Method in class com.apama.engine.beans.EngineClientBean
-
Get the inspectPollingInterval (in milliseconds) that the background thread should wait
between calls for new information.
- getInspectPollingInterval() - Method in interface com.apama.engine.beans.interfaces.InspectOperationsInterface
-
Get the inspectPollingInterval (in milliseconds) that the background thread should wait
between calls for new information.
- getInstance() - Method in class com.apama.jmon.PreparedEventExpressionTemplate
-
Create a new instance of the event expression template.
- getInstance(long) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get a single specific instance of this scenario, by instance ID.
- getInstances() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get all instances of this scenario.
- getInstancesForOwner(String) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get all instances of this scenario for a specific owner.
- getIntCellValue(int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Get the value of an integer cell in a data table.
- getInteger(int) - Method in class com.apama.correlator.memstore.RowValue
-
Get the n'th field of this type.
- getIntVar(String) - Method in interface com.apama.dashboard.data.IVariableData
-
Get the value of a variable as a int.
- getJavaApplications() - Method in interface com.apama.engine.EngineInfo
-
Get information for the set of Java (JMon) Applications that are/were live in the engine
at the point of inspection.
- getJavaType() - Method in enum com.apama.services.scenario.ParameterTypeEnum
-
Get the Java type (class) that is used to represent parameters of this type.
- getJmsMessage() - Method in class com.apama.correlator.jms.config.api.mapper.JmsSenderMessageHolder
-
- getKeyType() - Method in class com.apama.event.parser.DictionaryFieldType
-
Get the type of the keys
- getLastUpdateTime() - Method in interface com.apama.services.scenario.IScenarioInstance
-
Get the timestamp (milliseconds) of the last known update event for this instance.
- getLogger() - Static method in class com.apama.util.Logger
-
Factory method - use to get the default instance of a logger.
- getLogger(String) - Static method in class com.apama.util.Logger
-
Factory method - use to get an instance of a logger.
- getLogger(Class<?>) - Static method in class com.apama.util.Logger
-
Factory method - use to get an instance of a logger.
- getLogicalId() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getLogicalId() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the unique logical ID of the component
- getLogicalId() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentConnection
-
- getLogicalId() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the unique logical ID of the component
- getLogLevel() - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
Get the log level that should be used (if possible) for the 3rd party provider's logging.
- getLogLevel() - Method in class com.apama.iaf.plugin.IAFLogger
-
Deprecated.
- getLogLevel() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getLogLevel() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the component's current logging level
- getLogLevel() - Method in enum com.apama.net.interfaces.GenericComponentManagement.GenericComponentLogLevel
-
- getLogLevel() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the component's current logging level
- getLongCellValue(int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Get the value of a long cell in a data table.
- getMapFieldTypes(String) - Method in class com.apama.jmon.Event
-
This method should be overridden in any subclass that has fields of type
Map
.
- getMatchingEvent(String) - Method in class com.apama.jmon.MatchEvent
-
Get one of the co-assigned Events that caused the match.
- getMatchingEvents() - Method in class com.apama.jmon.MatchEvent
-
Get the set of co-assigned Events that caused the match.
- getMessageSourceId() - Method in class com.apama.correlator.jms.config.api.mapper.MappableApamaEvent
-
- getMicroTime() - Static method in class com.apama.util.TimestampSet
-
Get the current microsecond-accurate relative timestamp.
- getMonitorOnly() - Method in class com.apama.engine.beans.EngineClientBean
-
Getter for the monitorOnly property.
- getMonitors() - Method in interface com.apama.engine.EngineInfo
-
Get information for the set of Monitors that are/were live in the engine
at the point of inspection.
- getMonitorScriptType() - Method in enum com.apama.services.scenario.ParameterTypeEnum
-
Get the MonitorScript type that is used internally within the correlator for variable of this type.
- getMostBackedUpInput() - Method in interface com.apama.engine.EngineStatus
-
Get the name of the most backed up input context
- getMostBackedUpQueueSize() - Method in interface com.apama.engine.EngineStatus
-
Get the queue size of the most backed up input context
- getName() - Method in class com.apama.correlator.memstore.AbstractStore
-
Returns the unique id representing this store, which is also the name by which it is referenced from EPL.
- getName() - Method in interface com.apama.dashboard.command.ICommandDescriptor
-
Returns the name of the command.
- getName() - Method in interface com.apama.dashboard.function.IFunctionDescriptor
-
Get the name of the function.
- getName() - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Get the name of this consumer.
- getName() - Method in interface com.apama.engine.NameInfo
-
Get the name of the item.
- getName() - Method in class com.apama.epl.plugin.Context
-
Returns the name of the context.
- getName() - Method in class com.apama.event.Event
-
Retrieve the name of the event type.
- getName() - Method in class com.apama.event.parser.Field
-
Method to return the name of the field object
- getName() - Method in class com.apama.event.parser.FieldType
-
Return the name of this type.
- getName() - Method in class com.apama.iaf.plugin.EventCodecProperty
-
- getName() - Method in class com.apama.iaf.plugin.EventTransportProperty
-
- getName() - Method in class com.apama.jmon.Context
-
Returns the name of the context.
- getName(Class) - Static method in class com.apama.jmon.Event
-
Get the Correlator name for the specified Event subclass.
- getName() - Method in class com.apama.jmon.Event
-
Get the Correlator name for this Event subclass instance.
- getName() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getName() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the name of the component, encoded as UTF-8
- getName() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentConnection
-
- getName() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentInfo
-
- getName() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentInfoTuple
-
- getName() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the name of the component, encoded as UTF-8
- getName() - Method in interface com.apama.services.event.IEventServiceChannel
-
Get the name of the channel(s) that this instance is consuming events from.
- getNextEvents(Long[], Boolean[]) - Method in class com.apama.event.EventReader
-
Read the next (batch of) event(s) from the bufferedReader.
- getNumAggregates() - Method in interface com.apama.engine.EngineInfo
-
Get the number of aggregate functions that are/were live in the engine at the
point of inspection.
- getNumColumns() - Method in interface com.apama.dashboard.data.ITabularData
-
Get the number of columns in data table.
- getNumConsumers() - Method in interface com.apama.engine.EngineStatus
-
Get the number of event consumers connected to the
engine.
- getNumContexts() - Method in interface com.apama.engine.EngineInfo
-
Get the number of Contexts that are/were live in the engine
at the point of inspection.
- getNumContexts() - Method in interface com.apama.engine.EngineStatus
-
Get the number of contexts active in the Engine.
- getNumEventTemplates() - Method in interface com.apama.engine.NamedEventTypeInfo
-
Get the number of event templated that have been created besed on
this named Event Type.
- getNumEventTypes() - Method in interface com.apama.engine.EngineInfo
-
Get the number of Event Type definitions that are/were live in the engine
at the point of inspection.
- getNumEventTypes() - Method in interface com.apama.engine.EngineStatus
-
Get the number of event types defined.
- getNumFastTracked() - Method in interface com.apama.engine.EngineStatus
-
Get the number of events received on the internal input
queue since the Engine started.
- getNumJavaApplications() - Method in interface com.apama.engine.EngineInfo
-
Get the number of Java (JMon) Applications that are/were live in the engine
at the point of inspection.
- getNumJavaApplications() - Method in interface com.apama.engine.EngineStatus
-
Get the number of Java (JMon) Applications defined in the Engine.
- getNumListeners() - Method in interface com.apama.engine.EngineStatus
-
Get the number of active listeners.
- getNumListeners() - Method in interface com.apama.engine.NamedJavaApplicationInfo
-
Get the number of listeners for this JMon Application.
- getNumMonitors() - Method in interface com.apama.engine.EngineInfo
-
Get the number of Monitor definitions that are/were live in the engine
at the point of inspection.
- getNumMonitors() - Method in interface com.apama.engine.EngineStatus
-
Get the number of monitors defined in the Engine.
- getNumOutEventsCreated() - Method in interface com.apama.engine.EngineStatus
-
Gets the number of output events which have been
put onto the output queue.
- getNumOutEventsQueued() - Method in interface com.apama.engine.EngineStatus
-
Get the number of events waiting on the output queue.
- getNumOutEventsSent() - Method in interface com.apama.engine.EngineStatus
-
This is the number of output events sent out by the
correlator process.
- getNumPluginReceivers() - Method in interface com.apama.engine.EngineInfo
-
Get the number of Plugin Receivers that are/were in the engine
at the point of inspection.
- getNumProcessed() - Method in interface com.apama.engine.EngineStatus
-
Get the number of events taken off the input queue and processed
since the Engine started.
- getNumProcesses() - Method in interface com.apama.engine.EngineStatus
-
Get the number of monitor processes or active
sub-monitors.
- getNumQueuedFastTrack() - Method in interface com.apama.engine.EngineStatus
-
Get the number of events waiting on the internal input
queue.
- getNumQueuedInput() - Method in interface com.apama.engine.EngineStatus
-
Get the number of events waiting on the input queue.
- getNumReceived() - Method in interface com.apama.engine.EngineStatus
-
Get the number of events received since the Engine
started.
- getNumReceivers() - Method in interface com.apama.engine.EngineInfo
-
Get the number of Receivers that are/were connected to the engine
at the point of inspection.
- getNumRows() - Method in interface com.apama.dashboard.data.ITabularData
-
Get the number of rows in a data table.
- getNumSubListeners() - Method in interface com.apama.engine.EngineStatus
-
Get the number of active sub-listeners.
- getNumSubMonitors() - Method in interface com.apama.engine.NamedContextInfo
-
Get the number of sub-monitors for this Context
- getNumSubMonitors() - Method in interface com.apama.engine.NamedMonitorInfo
-
Get the number of sub-monitors for this Monitor.
- getNumTimers() - Method in interface com.apama.engine.EngineInfo
-
Get the number of timer types that are/were live in the engine
at the point of inspection.
- getNumTimers() - Method in interface com.apama.engine.NamedTimerInfo
-
Get the number of timers of this type
- getOutputParameterNames() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get the names of all output parameters for the scenario.
- getOutputParameterTypes() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Get the types of all output parameters for the scenario.
- getOwner() - Method in interface com.apama.services.scenario.IScenarioInstance
-
Get the owner (username) of the instance.
- getPackage() - Method in interface com.apama.engine.NameInfo
-
Get the package in which the item is installed.
- getPassword() - Method in interface com.apama.dashboard.security.IUserCredentials
-
Get the password.
- getPhysicalId() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getPhysicalId() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the globally unique physical ID of the component
- getPhysicalId() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentConnection
-
- getPhysicalId() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the globally unique physical ID of the component
- getPID() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
Return the process identifier of the remote server.
- getPID() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Return the component's process ID
- getPID() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Return the component's process ID
- getPluginReceivers() - Method in interface com.apama.engine.EngineInfo
-
Get information for the set of Plugin Receivers that are/were in the engine
at the point of inspection.
- getPort() - Method in class com.apama.engine.beans.EngineClientBean
-
Get the port number to be connected to.
- getPort() - Method in class com.apama.engine.EngineConnection
-
Get the port associated with this connection.
- getPort() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Get the port number to be connected to.
- getPort() - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Get the port number to be connected to.
- getPort() - Method in class com.apama.net.beans.PingBean
-
Get the port number to be connected to.
- getPriority() - Method in class com.apama.correlator.jms.config.api.mapper.JmsSenderMessageHolder
-
- getProcessName() - Method in class com.apama.engine.beans.EngineClientBean
-
Get the process Name in use
This is the process name in use for this bean
The process name is a display name to identify which application is responsible
for this connection to the Correlator (this name is included in log files for diagnostic purposes)
- getProcessName() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Get the processName in use
- getProcessName() - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Get the process name of this client
This is the process name used when initialising the client
- getProcessName() - Method in class com.apama.net.beans.PingBean
-
Get the process Name in use
This is the process name in use for this bean
- getProductVersion() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getProductVersion() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the version number of the product the component belongs to
- getProductVersion() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the version number of the product the component belongs to
- getQueueSize() - Method in interface com.apama.engine.NamedContextInfo
-
Get the current queue size for this Context
- getQueueSize() - Method in interface com.apama.engine.NamedPluginReceiverInfo
-
Get the current queue size for this Receiver
- getQueueSize() - Method in interface com.apama.engine.NamedReceiverInfo
-
Get the current queue size for this Receiver
- getReceiveOnly() - Method in class com.apama.engine.beans.EngineClientBean
-
Getter for the receiveOnly property.
- getReceiverId() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsReceiverMapperContext
-
- getReceiverMapperDelegate() - Method in class com.apama.correlator.jms.config.api.mapper.SimpleAbstractJmsMessageMapper
-
- getReceivers() - Method in interface com.apama.engine.EngineInfo
-
Get information for the set of Receivers that are/were connected to the engine
at the point of inspection.
- getReceivers() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentConnectionSet
-
- getRemoteEngineInfo() - Method in class com.apama.engine.beans.EngineClientBean
-
Request the remote Engine inspection info.
- getRemoteEngineInfo() - Method in interface com.apama.engine.beans.interfaces.InspectOperationsInterface
-
Request the remote Engine inspection info.
- getRemoteHost() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentConnection
-
- getRemotePhysicalComponentID() - Method in interface com.apama.engine.EngineManagement
-
Obtain a unique ID for the component that this object is connected to.
- getRemotePort() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getRemotePort() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the port number that the component is listening on
- getRemotePort() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentConnection
-
- getRemotePort() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the port number that the component is listening on
- getRemoteStatus() - Method in class com.apama.engine.beans.EngineClientBean
-
Request the remote Engine status.
- getRemoteStatus() - Method in interface com.apama.engine.beans.interfaces.WatchOperationsInterface
-
Request the remote Engine status.
- getReturnColumnNames() - Method in interface com.apama.dashboard.function.IFunctionDescriptor
-
Get the columns names if the function returns a table.
- getReturnType() - Method in interface com.apama.dashboard.function.IFunctionDescriptor
-
Get the return type of the function.
- getRowChangedOldValueRequired() - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
Retrieve whether subscribers should receive old values in RowChanged events.
- getRowChangedSubscriptionManager() - Method in class com.apama.correlator.memstore.AbstractTable
-
- getRowNames() - Method in interface com.apama.dashboard.data.ITabularData
-
Get the names of the rows in a data table.
- getScenarioById(String) - Method in interface com.apama.services.scenario.IScenarioService
-
Get a ScenarioDefinition for a specific scenario, using the ScenarioId as the lookup key.
- getScenarioByName(String) - Method in interface com.apama.services.scenario.IScenarioService
-
Get a ScenarioDefinition for a specific scenario, using the Display Name as the lookup key.
- getScenarioDefinition() - Method in interface com.apama.services.scenario.IScenarioInstance
-
Get the Scenario Definition.
- getScenarioIds() - Method in interface com.apama.services.scenario.IScenarioService
-
Get the IDs of all known scenarios (not instances) in the correlator.
- getScenarioNames() - Method in interface com.apama.services.scenario.IScenarioService
-
Get the Display Names of all known scenarios (not instances) in the correlator.
- getScenarios() - Method in interface com.apama.services.scenario.IScenarioService
-
Get the ScenarioDefinitions of all known scenarios in the correlator.
- getScenarioType() - Method in enum com.apama.services.scenario.ParameterTypeEnum
-
Get the type as defined in the Scenario definition file (sdf), and which
is also returned from the correlator.
- getSenderId() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsSenderMapperContext
-
- getSenderMapperDelegate() - Method in class com.apama.correlator.jms.config.api.mapper.SimpleAbstractJmsMessageMapper
-
- getSenders() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentConnectionSet
-
- getSession() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsSenderMapperContext
-
- getSlowestReceiver() - Method in interface com.apama.engine.EngineStatus
-
Get the name of the slowest receiver
- getSlowestReceiverQueueSize() - Method in interface com.apama.engine.EngineStatus
-
Get the queue size of the slowest receiver
- getState() - Method in interface com.apama.services.scenario.IScenarioInstance
-
Get the current state of the instance.
- getStatus() - Method in class com.apama.engine.beans.EngineClientBean
-
Get the most recently recorded status.
- getStatus() - Method in interface com.apama.engine.beans.interfaces.WatchOperationsInterface
-
Get the most recently recorded status.
- getStatus() - Method in interface com.apama.engine.EngineManagement
-
Get the Engine's current operational status.
- getStatus() - Method in class com.apama.iaf.plugin.AbstractEventCodec
-
- getStatus() - Method in class com.apama.iaf.plugin.AbstractEventTransport
-
- getStatus() - Method in class com.apama.iaf.plugin.CodecStatus
-
- getStatus() - Method in class com.apama.iaf.plugin.TransportStatus
-
- getStatusPollingInterval() - Method in class com.apama.engine.beans.EngineClientBean
-
Get the statusPollingInterval (in milliseconds) that the background thread should wait
between calls for new status information.
- getStatusPollingInterval() - Method in interface com.apama.engine.beans.interfaces.WatchOperationsInterface
-
Get the statusPollingInterval (in milliseconds) that the background thread should wait
between calls for new status information.
- getStoreName() - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
The unique storeName for this factory, specified by the id attribute in the configuration.
- getString(int) - Method in class com.apama.correlator.memstore.RowValue
-
Get the n'th string field.
- getStringBytes(int) - Method in class com.apama.correlator.memstore.RowValue
-
Get the n'th string field of this type as a null-terminated array of UTF-8 bytes
(which is currently the in-memory storage format for strings).
- getStringValue() - Method in class com.apama.event.parser.DecimalFieldValue
-
Get the string representation, This is the original string value(or the BigDecimal converted)
- getStringVar(String) - Method in interface com.apama.dashboard.data.IVariableData
-
Get the value of a variable as a String.
- getSubject() - Method in interface com.apama.dashboard.security.IUserCredentials
-
Get the javax security subject for this user.
- getSubstitutionValue(String) - Method in interface com.apama.dashboard.IDashboardContext
-
Gets the value of a substitution.
- getTableVar(String) - Method in interface com.apama.dashboard.data.IVariableData
-
Get the value of a variable as TabularData.
- getTemplateString() - Method in class com.apama.jmon.PreparedEventExpressionTemplate
-
Get the String value of the PreparedEventExpressionTemplate.
- getText() - Method in class com.apama.engine.MonitorScript
-
Retrieve the text of a MonitorScript fragment as a String.
- getText() - Method in class com.apama.event.Event
-
Retrieve the Apama string representation of the event.
- getTime() - Method in class com.apama.event.Event
-
Method to retrieve the timestamp for the event.
- getTime() - Method in class com.apama.jmon.Event
-
Get the time that the event arrived at the correlator.
- getTimers() - Method in interface com.apama.engine.EngineInfo
-
Get information for the set of timer types that are/were live in the engine
at the point of inspection.
- getTimeToLive() - Method in class com.apama.correlator.jms.config.api.mapper.JmsSenderMessageHolder
-
- getTotalClusterMembers() - Method in class com.apama.correlator.memstore.AbstractStore
-
Returns the total number of cluster members in this store.
- getTotalReceived() - Method in class com.apama.iaf.plugin.TransportStatus
-
- getTotalSent() - Method in class com.apama.iaf.plugin.TransportStatus
-
- getType() - Method in class com.apama.event.parser.Field
-
Method to return the FieldType of the field object
- getType() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getType() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the type of the component, encoded as UTF-8
- getType() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the type of the component, encoded as UTF-8
- getTypeClass() - Method in class com.apama.event.parser.FieldType
-
Return the Java type used for parsed values of this field type.
- getTypedIndex(int) - Method in class com.apama.correlator.memstore.RowValueHelper
-
Use the schema types to get the typedIndex (suitable for a RowValue.set/get call) from
a fieldIndex.
- getTypeName(String) - Static method in class com.apama.event.parser.EventParser
-
Method to extract and return the event type name from an event string.
- getUniqueMessageId() - Method in class com.apama.correlator.jms.config.api.mapper.MappableApamaEvent
-
- getUptime() - Method in interface com.apama.engine.EngineStatus
-
Get the time in ms that the Engine has been running
for.
- getUsername() - Method in interface com.apama.dashboard.security.IUserCredentials
-
Get the username
- getUsername() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- getUsername() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Get the effective username the component is running as
- getUsername() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Get the effective username the component is running as
- getValidationFailureMessages() - Method in exception com.apama.services.scenario.InvalidInputParameterException
-
Get an unmodifiable view of the internal map of validation failure
messages.
- getValue() - Method in class com.apama.event.parser.DecimalFieldValue
-
Get the value as a BigDecimal.
- getValue() - Method in class com.apama.iaf.plugin.EventCodecProperty
-
- getValue() - Method in class com.apama.iaf.plugin.EventTransportProperty
-
- getValue() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentInfoTuple
-
- getValue(String) - Method in interface com.apama.services.scenario.IScenarioInstance
-
Get the value of a single specific (input or output) parameter of this instance.
- getValueType() - Method in class com.apama.event.parser.DictionaryFieldType
-
Get the type of the values
- getVarNames() - Method in interface com.apama.dashboard.data.IVariableData
-
Get the variable names.
- getVarTypes() - Method in interface com.apama.dashboard.data.IVariableData
-
Get the variable types.
- getVerbose() - Method in class com.apama.engine.beans.EngineClientBean
-
Getter for the verbose property.
- getVerbose() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Getter for the verbose property.
- getWarnings() - Method in exception com.apama.EngineException
-
Get an array of warnings which might have been returned along
with the error.
- getWrappedException() - Method in exception com.apama.EngineException
-
Deprecated.
This method has been renamed to CompoundException.getCause()
as part
of an API review and may be deleted in a future release.
- getX1() - Method in class com.apama.event.parser.LocationType
-
Returns the x component of the first point that describes the rectangular area.
- getX2() - Method in class com.apama.event.parser.LocationType
-
Returns the x component of the second point that describes the rectangular area.
- getY1() - Method in class com.apama.event.parser.LocationType
-
Returns the y component of the first point that describes the rectangular area.
- getY2() - Method in class com.apama.event.parser.LocationType
-
Returns the y component of the second point that describes the rectangular area.
- IAFLogger - Class in com.apama.iaf.plugin
-
Deprecated.
Use Logger
instead. This class will be
removed in a future release.
- IAFLogger(String) - Constructor for class com.apama.iaf.plugin.IAFLogger
-
Deprecated.
Constructs an IAFLogger for this transport or codec.
- IAFLogger() - Constructor for class com.apama.iaf.plugin.IAFLogger
-
Deprecated.
Constructs an IAFLogger for this transport or codec, without
specifying a name to be prepended to messages.
- ICommandDescriptor - Interface in com.apama.dashboard.command
-
ICommandDescriptor is an interface that represents a description of a
DashboardStudio command.
- ICommandLibrary - Interface in com.apama.dashboard.command
-
ICommandLibrary is the interface a Dashboard Studio custom command library
must implement.
- IDashboardContext - Interface in com.apama.dashboard
-
IDashboardContext is an interface to an instance of a dashboard or
dashboard panel.
- IEventAuthority - Interface in com.apama.dashboard.security
-
An IEventAuthority authorizes users for sending an event
to the correlator.
- IEventListener - Interface in com.apama.event
-
IEventListener specifies the interface that classes must implement
to receive events from an EventServiceChannel.
- IEventService - Interface in com.apama.services.event
-
IEventService is an interface that represents the public API to the EventService.
- IEventServiceChannel - Interface in com.apama.services.event
-
IEventServiceChannel is the public interface for a class that represents
a channel or channels on which events are received from a Correlator.
- IFunctionDescriptor - Interface in com.apama.dashboard.function
-
IFunctionDescriptor is an interface that represents a description of a
DashboardSutdio function.
- IFunctionLibrary - Interface in com.apama.dashboard.function
-
IFunctionLibrary is the interface a Dashboard Studio custom function library
must implement.
- IllegalCallingThreadException - Exception in com.apama.services.scenario
-
Thrown when an attempt is made to change the state of running
scenarios in the data queue processing thread.
- IllegalCallingThreadException(String) - Constructor for exception com.apama.services.scenario.IllegalCallingThreadException
-
- IMacroPreprocessor - Interface in com.apama.dashboard.security
-
IMacroPreprocessor class provides a hook for user to resolve macros
inside any attachment strings in the Instance Table Query attachment.
- IMacroPreprocessor.ATTACHMENT_TYPE - Enum in com.apama.dashboard.security
-
Enum type to indicate the type of attachment when the process() method
is called.
- info(String) - Method in class com.apama.util.Logger
-
Logs the specified message at INFO level.
- info(String, Throwable) - Method in class com.apama.util.Logger
-
Logs the specified message at INFO level, followed by a stack trace for the exception.
- INFO_STR - Static variable in class com.apama.util.Logger
-
- infoEnabled() - Method in class com.apama.util.Logger
-
Determines if the logging is enabled at the INFO level for this Logger instance.
- init() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsReceiverMapperFactory
-
Initialization method to be called once all configuration properties have been assigned, to initialize this factory and validate the
configuration.
- init() - Method in interface com.apama.correlator.jms.config.api.mapper.JmsSenderMapperFactory
-
Initialization method to be called after all configuration properties have been assigned, to initialize this factory and validate the
configuration.
- init() - Method in class com.apama.correlator.jms.config.api.mapper.SimpleAbstractJmsMessageMapper
-
- init() - Method in class com.apama.correlator.memstore.AbstractStore
-
Initialization method that is called by distributed MemoryStore just after construction.
- initializeProviderSystemProperty(String, String) - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
Helper method for setting the value of a JVM-wide system property which is required by this store.
- injectCDP(byte[]) - Method in class com.apama.engine.beans.EngineClientBean
-
Send the bytes of a CDP (Correlator Deployment Package) to the engine without blocking
concurrent calls to operations on this bean instance.
- injectCDP(byte[], String) - Method in class com.apama.engine.beans.EngineClientBean
-
Send the bytes of a CDP (Correlator Deployment Package) to the engine without blocking
concurrent calls to operations on this bean instance.
- injectCDP(byte[], String) - Method in interface com.apama.engine.beans.interfaces.InjectOperationsInterface
-
Send the bytes of a CDP (Correlator Deployment Package) to the engine.
- injectCDP(byte[], String) - Method in interface com.apama.engine.EngineManagement
-
Injects a CDP (Correlator Deployment Package) into the engine.
- injectCDPsFromFile(List<String>) - Method in class com.apama.engine.beans.EngineClientBean
-
Inject a collection of CDPs read from files (or stdin),
without blocking concurrent calls to operations on this bean instance.
- injectCDPsFromFile(List<String>) - Method in interface com.apama.engine.beans.interfaces.InjectOperationsInterface
-
Inject a number of CDP (Correlator Deployment Package)(s) from a file or stdin.
- INJECTIONFAILURE - Static variable in exception com.apama.iaf.plugin.SemanticMapperException
-
Couldn't queue converted event for injection into the Engine
- injectJava(byte[]) - Method in interface com.apama.engine.EngineManagement
-
Injects a Java application (a jar) into the engine.
- injectJavaApplication(byte[]) - Method in class com.apama.engine.beans.EngineClientBean
-
Send the bytes of a JMon application jar to the engine without blocking
concurrent calls to operations on this bean instance.
- injectJavaApplication(byte[]) - Method in interface com.apama.engine.beans.interfaces.InjectOperationsInterface
-
Send the bytes of a Java (JMon) Application jar to the engine.
- injectJavaApplicationsFromFile(List<String>) - Method in class com.apama.engine.beans.EngineClientBean
-
Inject a collection of JMon application jars read from files (or stdin),
without blocking concurrent calls to operations on this bean instance.
- injectJavaApplicationsFromFile(List<String>) - Method in interface com.apama.engine.beans.interfaces.InjectOperationsInterface
-
Inject a number of Java (JMon) Application(s) from a file or stdin.
- injectMonitorScript(MonitorScript) - Method in class com.apama.engine.beans.EngineClientBean
-
Send MonitorScript text to the engine without blocking concurrent calls
to operations on this bean instance.
- injectMonitorScript(MonitorScript, String) - Method in class com.apama.engine.beans.EngineClientBean
-
- injectMonitorScript(MonitorScript) - Method in interface com.apama.engine.beans.interfaces.InjectOperationsInterface
-
Send a MonitorScript object to the engine.
- injectMonitorScript(MonitorScript, String) - Method in interface com.apama.engine.beans.interfaces.InjectOperationsInterface
-
Send a MonitorScript object to the engine.
- injectMonitorScript(MonitorScript) - Method in interface com.apama.engine.EngineManagement
-
Inject MonitorScript text into the Engine.
- injectMonitorScript(MonitorScript, String) - Method in interface com.apama.engine.EngineManagement
-
Inject MonitorScript text into the Engine.
- injectMonitorScriptFromFile(String...) - Method in class com.apama.engine.beans.EngineClientBean
-
Inject a collection of MonitorScript text read from files (or stdin),
without blocking concurrent calls to operations on this bean instance.
- injectMonitorScriptFromFile(List<String>) - Method in class com.apama.engine.beans.EngineClientBean
-
Inject a collection of MonitorScript text read from files (or stdin),
without blocking concurrent calls to operations on this bean instance.
- injectMonitorScriptFromFile(List<String>, boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
- injectMonitorScriptFromFile(String...) - Method in interface com.apama.engine.beans.interfaces.InjectOperationsInterface
-
Inject a number of monitors from a file or stdin.
- injectMonitorScriptFromFile(List<String>) - Method in interface com.apama.engine.beans.interfaces.InjectOperationsInterface
-
Inject a number of monitors from a file or stdin.
- injectMonitorScriptFromFile(List<String>, boolean) - Method in interface com.apama.engine.beans.interfaces.InjectOperationsInterface
-
Inject a number of monitors from a file or stdin.
- InjectOperationsInterface - Interface in com.apama.engine.beans.interfaces
-
InjectOperationsInterface is an interface that specifies the standard operations to
enable an engine client to inject new code into a remote correlator.
- insertColumnAt(String, int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Insert a column into the data table.
- insertRowAt(String, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Insert a new row into the data table.
- inspectEngine() - Method in interface com.apama.engine.EngineManagement
-
Ask the Engine for information about the internal state.
- InspectOperationsInterface - Interface in com.apama.engine.beans.interfaces
-
InspectOperationsInterface is an interface that specifies the standard orperations to
enable an engine client to gather information from a remote correlator about
the set of Monitors and Event Types that it is currently working with.
- InstanceStateEnum - Enum in com.apama.services.scenario
-
Enum class to handle the StateChange event.
- INTEGER - Static variable in class com.apama.event.parser.FieldTypes
-
Get the singleton field type object for the Apama integer type,
for which values are specified as Java Long
objects.
- IntegerFieldType - Class in com.apama.event.parser
-
Represents the Apama integer
type,
for which values are specified as Long
objects.
- INTERNALERROR - Static variable in exception com.apama.iaf.plugin.CodecException
-
Some unspecified internal error occurred
- INTERNALERROR - Static variable in exception com.apama.iaf.plugin.SemanticMapperException
-
Some unspecified internal error occurred
- INTERNALERROR - Static variable in exception com.apama.iaf.plugin.TransportException
-
Some unspecified internal error occurred
- InterruptedEngineException - Exception in com.apama
-
An InterruptedEngineException is thrown by various methods of classes
in the Engine Client SDK if the thread calling is interrupted.
- InterruptedEngineException(String) - Constructor for exception com.apama.InterruptedEngineException
-
Create a simple exception with the given message.
- InterruptedEngineException(Throwable) - Constructor for exception com.apama.InterruptedEngineException
-
Create a compound exception that references the given exception.
- InterruptedEngineException(String, Throwable) - Constructor for exception com.apama.InterruptedEngineException
-
Create a compound exception with the given message and that references the given exception.
- InvalidInputParameterException - Exception in com.apama.services.scenario
-
InvalidInputParameterException is a specialized exception class that is used
by classes of the Scenario Service to indicate that an invalid input parameter
has been provided to create or edit a ScenarioInstance.
- InvalidInputParameterException() - Constructor for exception com.apama.services.scenario.InvalidInputParameterException
-
- InvalidInputParameterException(String) - Constructor for exception com.apama.services.scenario.InvalidInputParameterException
-
- InvalidInputParameterException(String, Throwable) - Constructor for exception com.apama.services.scenario.InvalidInputParameterException
-
- InvalidInputParameterException(Throwable) - Constructor for exception com.apama.services.scenario.InvalidInputParameterException
-
- invokeCommand(String, Object) - Method in interface com.apama.dashboard.command.ICommandLibrary
-
Invoke a command.
- IResponseListener - Interface in com.apama.services.event
-
IResponseListener specifies the interface that classes must implement
to receive the response part of an asynchronous request-response call.
- IResponseWrapper - Interface in com.apama.services.event
-
IResponseWrapper is an interface that specifies the public API for objects
returned by the various request-response methods of the Event Service.
- isAllConsumersConnected() - Method in class com.apama.engine.beans.EngineClientBean
-
- isAllConsumersConnected() - Method in interface com.apama.engine.beans.interfaces.ReceiveConsumerOperationsInterface
-
Determine if the bean and existing uniquely-named consumers are connected.
- isBeanConnected() - Method in class com.apama.engine.beans.EngineClientBean
-
Another name for the getBeanConnected() method.
- isBeanConnected() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Another name for the getBeanConnected() method.
- isBeanConnected() - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Another name for the getBeanConnected() method.
- isBeanConnected() - Method in class com.apama.net.beans.PingBean
-
Another name for the getBeanConnected() method.
- IScenarioAuthority - Interface in com.apama.dashboard.security
-
An IScenarioAuthority authorizes users for viewing, editing,
deleting, and creating scenarios.
- IScenarioDefinition - Interface in com.apama.services.scenario
-
IScenarioDefinition is the public interface for a class that represents
a Scenario (not an instance).
- IScenarioInstance - Interface in com.apama.services.scenario
-
IScenarioInstance is the public interface for a class that represents
a Scenario instance.
- IScenarioService - Interface in com.apama.services.scenario
-
IScenarioService is an interface that represents the public API to the
ScenarioService.
- isConnected() - Method in interface com.apama.engine.EngineManagement
-
This method is used to check that the Engine is
still connected.
- isConnected() - Method in interface com.apama.services.event.IEventService
-
Get the current connectivity of the event service.
- isConsumerConnected() - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Determine if this consumer is really connected to the remote Correlator.
- isCritEnabled() - Method in class com.apama.iaf.plugin.IAFLogger
-
Deprecated.
Returns true if critical level logging is enabled
- isDebugEnabled() - Method in class com.apama.iaf.plugin.IAFLogger
-
Deprecated.
Returns true if debug level logging is enabled
- isDestroyed() - Method in interface com.apama.services.event.IEventService
-
Determine if this service (not the Correlator) is disposed.
- isDestroyed() - Method in interface com.apama.services.event.IEventServiceChannel
-
Determine if this EventServiceChannel channel (not the Correlator) is destroyed,
which is true if it has been removed from the parent EventService using
IEventService.removeChannel(String)
.
- isDestroyed() - Method in interface com.apama.services.scenario.IScenarioService
-
Determine if this service is disposed.
- isEmpty() - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Returns true if this map contains no key-value mappings.
- isEmpty() - Method in class com.apama.util.TimestampSet
-
Returns true if this map contains no index-time mappings.
- isErrorEnabled() - Method in class com.apama.iaf.plugin.IAFLogger
-
Deprecated.
Returns true if error level logging is enabled
- isExternal() - Method in class com.apama.jmon.Event
-
Determine if this is an "external" event - if it originated outside the correlator.
- isFatalEnabled() - Method in class com.apama.iaf.plugin.IAFLogger
-
Deprecated.
Returns true if fatal level logging is enabled
- isGenericComponentManagementAvailable() - Method in class com.apama.net.beans.GenericComponentManagementBean
-
Return true if the remote server actually implements the
GenericComponentManagement interface.
- isGenericComponentManagementAvailable() - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Returns true if the GenericComponentManagement interface is available
- isInfinity() - Method in class com.apama.event.parser.DecimalFieldValue
-
Test whether the value is an infinity
- isInfoEnabled() - Method in class com.apama.iaf.plugin.IAFLogger
-
Deprecated.
Returns true if info level logging is enabled
- isInputParameter(String) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Test if a specific named parameter is an input parameter.
- isMonitorOnly() - Method in class com.apama.engine.beans.EngineClientBean
-
Another name for getMonitorOnly()
- isNaN() - Method in class com.apama.event.parser.DecimalFieldValue
-
Test whether value is not a number
- isOutputParameter(String) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Test if a specific named parameter is an output parameter.
- isPolling() - Method in class com.apama.net.beans.PingBean
-
Determine if the connection is being tested in a background thread.
- isPublic() - Method in class com.apama.epl.plugin.Context
-
Returns true if the context is public (receives external / enqueued events)
- isPublic() - Method in class com.apama.jmon.Context
-
Returns true if the context is public (receives external / enqueued events)
- isReadOnly() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Return if the Scenario is read only or can have instances created, edited and deleted.
- isReceiveOnly() - Method in class com.apama.engine.beans.EngineClientBean
-
Another name for getReceiveOnly()
- isSlow() - Method in interface com.apama.net.interfaces.GenericComponentManagement.GenericComponentReceiver
-
- isWarnEnabled() - Method in class com.apama.iaf.plugin.IAFLogger
-
Deprecated.
Returns true if warn level logging is enabled
- ITabularData - Interface in com.apama.dashboard.data
-
ITabularData is an interface to an instance of Dashboard Studio tabular
data.
- iterator() - Method in class com.apama.correlator.memstore.AbstractTable
-
Returns an iterator over all the rows of this table.
- iterator() - Method in class com.apama.correlator.memstore.ConcurrentMapAdapter
-
- iterator() - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Returns a standard Java Iterator over the contents of the NormalisedEvent using
Map.Entry
objects.
- iterator() - Method in class com.apama.util.TimestampSet
-
Returns a standard Java Iterator over the contents of the TimestampSet using
Map.Entry
objects.
- IUserCredentials - Interface in com.apama.dashboard.security
-
UserCredentials contain information about a user attempting to
access data or perform an operation.
- IVariableData - Interface in com.apama.dashboard.data
-
IVariableData is an interface to an instance of a class containing
the current values of a set of dashboard variables.
- ParameterTypeEnum - Enum in com.apama.services.scenario
-
Enum class to model the "type" of scenario input/output parameters.
- parse(String) - Method in class com.apama.event.parser.BooleanFieldType
-
Convert a value of this type from the format used in Apama event strings, into
a Boolean object.
- parse(String) - Method in class com.apama.event.parser.ChannelFieldType
-
Convert a value of this type from the format used in Apama event strings, into
a String object.
- parse(String) - Method in class com.apama.event.parser.DecimalFieldType
-
Convert a value of this type from the format used in Apama event strings, into
a DecimalFieldValue object.
- parse(String) - Method in class com.apama.event.parser.DictionaryFieldType
-
Convert a value of this type from the format used in Apama event strings, into
a Map object.
- parse(String) - Method in class com.apama.event.parser.EventParser
-
Parse an event string.
- parse(String) - Method in class com.apama.event.parser.EventType
-
Convert a value of this type from the format used in Apama event strings, into
an Event object.
- parse(String) - Method in class com.apama.event.parser.FieldType
-
Parse an Apama string representation of this field type into
an object representing its value.
- parse(String) - Method in class com.apama.event.parser.FloatFieldType
-
Convert a value of this type from the format used in Apama event strings, into
a Double object.
- parse(String) - Method in class com.apama.event.parser.IntegerFieldType
-
Convert a value of this type from the format used in Apama event strings, into
a Long object.
- parse(String) - Method in class com.apama.event.parser.LocationFieldType
-
Convert a value of this type from the format used in Apama event strings, into
a LocationType object.
- parse(String) - Method in class com.apama.event.parser.SequenceFieldType
-
Convert a value of this type from the format used in Apama event strings, into
a List object.
- parse(String) - Method in class com.apama.event.parser.StringFieldType
-
Convert a value of this type from the format used in Apama event strings, into
a String object containing the string's contents (without the surrounding quotes and
any escape characters).
- ParserRuntimeException - Exception in com.apama.event.parser
-
ParserRuntimeException will be thrown when an error occurs while parsing an Apama event.
- ParserRuntimeException(String) - Constructor for exception com.apama.event.parser.ParserRuntimeException
-
- ParserRuntimeException(Throwable) - Constructor for exception com.apama.event.parser.ParserRuntimeException
-
- ParserRuntimeException(String, Throwable) - Constructor for exception com.apama.event.parser.ParserRuntimeException
-
- performsEscapingDownstream() - Method in interface com.apama.iaf.plugin.ConfigurableCodec
-
Whether or not the codec performs escaping downstream.
- ping() - Method in interface com.apama.engine.EngineManagement
-
This method is used to check that the Engine is
still alive.
- ping() - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
This method is used to check that the component is still alive.
- ping() - Method in interface com.apama.net.interfaces.PingableClient
-
This method is used to check that the TCP server is
still alive.
- PingableClient - Interface in com.apama.net.interfaces
-
The PingableClient interface is the interface to any Apama TCP server,
and allows clients to detect if the server is alive.
- PingableClientFactory - Class in com.apama.net.interfaces
-
- PingBean - Class in com.apama.net.beans
-
PingBean is a JavaBean that provides a mechanism for pinging any Apama TCP
server that offers the Pingable interface (that should be all of them).
- PingBean() - Constructor for class com.apama.net.beans.PingBean
-
Default constructor - as required to be a bean.
- PingBean(String, int, String) - Constructor for class com.apama.net.beans.PingBean
-
Full argument constructor.
- PingClientInterface - Interface in com.apama.net.beans.interfaces
-
- PingOperationsInterface - Interface in com.apama.net.beans.interfaces
-
- pingServer() - Method in class com.apama.engine.beans.EngineClientBean
-
Manually test if the remote engine process is alive and responding to client requests.
- pingServer() - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Manually test if the remote agent process is alive and responding to
client requests.
- pingServer() - Method in interface com.apama.net.beans.interfaces.PingOperationsInterface
-
Manually test if the remote server process is alive and responding to client requests.
- pingServer() - Method in class com.apama.net.beans.PingBean
-
Manually test if the remote server process is alive and responding to client requests.
- pluginMethodBlocking() - Static method in class com.apama.epl.plugin.Correlator
-
Methods declared as non-blocking can opt to block by calling this method.
- PreparedEventExpression - Class in com.apama.jmon
-
- PreparedEventExpressionException - Exception in com.apama.jmon
-
Exception thrown when illegal operations are performed on a
PreparedEventExpression object.
- PreparedEventExpressionException(String) - Constructor for exception com.apama.jmon.PreparedEventExpressionException
-
Constructs a new exception with the specified detail message.
- PreparedEventExpressionTemplate - Class in com.apama.jmon
-
Instances of this class are declared to represent templates for "Prepared
Event Expressions".
- PreparedEventExpressionTemplate(String) - Constructor for class com.apama.jmon.PreparedEventExpressionTemplate
-
Constructor to create a new instance with the given immutable
expression template string.
- process(IMacroPreprocessor.ATTACHMENT_TYPE, String, Map<String, String>) - Method in interface com.apama.dashboard.security.IMacroPreprocessor
-
This method is called right before we process the attachment strings
so customer's implementation will have a chance to resolve any macros
according to the extraParam entries.
- PRODUCTNAME - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
The name of the product - this is just one component of the name that the user sees.
- PROP_DEFAULT_ACKDATA_TIMEOUT - Static variable in interface com.apama.services.scenario.IScenarioService
-
System property (in millisecond) to set the default AckData Timeout.
- PROP_DEFAULT_REQUEST_RESPONSE_TIMEOUT - Static variable in interface com.apama.services.event.IEventServiceChannel
-
System property (in millisecond) to set the default RequestResponseTimeout.
- PROP_OVERRIDE_ACKDATA_TIMEOUT - Static variable in interface com.apama.services.scenario.IScenarioService
-
System property (in millisecond) to override AckData Timeout.
- PROP_OVERRIDE_REQUEST_RESPONSE_TIMEOUT - Static variable in interface com.apama.services.event.IEventServiceChannel
-
System property (in millisecond) to override RequestResponseTimeout.
- PROPERTY_ALL_CONSUMERS_CONNECTED - Static variable in interface com.apama.engine.beans.interfaces.ReceiveConsumerOperationsInterface
-
The string name of the bound property that is used to indicate if the bean and all
individual named consumers are connected
(typically "allConsumersConnected", but this constant should be used to be sure).
- PROPERTY_BEAN_CONNECTED - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
The string name of the bound property that is used for "beanConnected" updates
(typically "beanConnected", but this constant should be used to be sure).
- PROPERTY_CONNECTED - Static variable in interface com.apama.services.event.IEventService
-
Property name for events fired that signal a change in the connectivity of the event service.
- PROPERTY_CONNECTION_POLLING_INTERVAL - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
The string name of the bound property that is used for "connectionPollingInterval" updates
(typically "connectionPollingInterval", but this constant should be used to be sure).
- PROPERTY_CONSUMER_CHANNELS - Static variable in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
The string name of the bound property that is used for "consumerChannels" updates
(typically "consumerChannels", but this constant should be used to be sure).
- PROPERTY_CONSUMER_CONNECTED - Static variable in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
The string name of the bound property that is used for "consumerConnected" updates
(typically "consumerConnected", but this constant should be used to be sure).
- PROPERTY_ENGINE_INFO - Static variable in interface com.apama.engine.beans.interfaces.InspectOperationsInterface
-
The string name of the bound property that is used for EngineInfo updates
(typically "engineInfo", but this constant should be used to be sure).
- PROPERTY_HOST - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
The string name of the bound property that is used for "host" updates
(typically "host", but this constant should be used to be sure).
- PROPERTY_INSPECT_POLLING_INTERVAL - Static variable in interface com.apama.engine.beans.interfaces.InspectOperationsInterface
-
The string name of the bound property that is used for inspectPollingInterval updates
(typically "inspectPollingInterval", but this constant should be used to be sure).
- PROPERTY_INSTANCE_ADDED - Static variable in interface com.apama.services.scenario.IScenarioDefinition
-
Property name for events fired that signal a new ScenarioInstance has been added.
- PROPERTY_INSTANCE_DIED - Static variable in interface com.apama.services.scenario.IScenarioDefinition
-
Property name for events fired that signal a ScenarioInstance has died unexpectedly.
- PROPERTY_INSTANCE_DISCOVERY_STATUS - Static variable in interface com.apama.services.scenario.IScenarioDefinition
-
Property name for events fired that signal the status of the internal
mechanism for discovering scenario instances in the Correlator.
- PROPERTY_INSTANCE_EDITED - Static variable in interface com.apama.services.scenario.IScenarioDefinition
-
Property name for events fired that signal a ScenarioInstance has been edited.
- PROPERTY_INSTANCE_REMOVED - Static variable in interface com.apama.services.scenario.IScenarioDefinition
-
Property name for events fired that signal an existing ScenarioInstance has been removed.
- PROPERTY_INSTANCE_STATE_CHANGE - Static variable in interface com.apama.services.scenario.IScenarioDefinition
-
Property name for events fired that signal an existing ScenarioInstance has changed state.
- PROPERTY_INSTANCE_UPDATED - Static variable in interface com.apama.services.scenario.IScenarioDefinition
-
Property name for events fired that signal a ScenarioInstance has been updated.
- PROPERTY_MONITOR_ONLY - Static variable in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
The string name of the bound property that is used for "monitorOnly" updates.
- PROPERTY_PORT - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
The string name of the bound property that is used for "port" updates
(typically "port", but this constant should be used to be sure).
- PROPERTY_PROCESS_NAME - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
The string name of the bound property that is used for "processName" updates
(typically "processName", but this constant should be used to be sure).
- PROPERTY_RECEIVE_ONLY - Static variable in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
The string name of the bound property that is used for "receiveOnly" updates.
- PROPERTY_SCENARIO_ADDED - Static variable in interface com.apama.services.scenario.IScenarioService
-
Property name for events fired that signal a new ScenarioDefinition has been added.
- PROPERTY_SCENARIO_DISCOVERY_STATUS - Static variable in interface com.apama.services.scenario.IScenarioService
-
Property name for events fired that signal the status of the internal
mechanism for discovering scenario definitions in the Correlator.
- PROPERTY_SCENARIO_REMOVED - Static variable in interface com.apama.services.scenario.IScenarioService
-
Property name for events fired that signal an existing ScenarioDefinition has been removed.
- PROPERTY_SCENARIO_SERVICE_UNLOADED - Static variable in interface com.apama.services.scenario.IScenarioService
-
Property name for events fired that signal the ScenarioService has been unloaded.
- PROPERTY_STATUS - Static variable in interface com.apama.engine.beans.interfaces.WatchOperationsInterface
-
The string name of the bound property that is used for status updates
(typically "status", but this constant should be used to be sure).
- PROPERTY_STATUS_POLLING_INTERVAL - Static variable in interface com.apama.engine.beans.interfaces.WatchOperationsInterface
-
The string name of the bound property that is used for statusPollingInterval updates
(typically "statusPollingInterval", but this constant should be used to be sure).
- PROPERTY_VERBOSE - Static variable in interface com.apama.net.beans.interfaces.BaseClientInterface
-
The string name of the bound property that is used for "verbose" updates
(typically "verbose", but this constant should be used to be sure).
- put(String, String) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Adds or replaces the specified (key,value) pair in the underlying map
- put(Integer, Double) - Method in class com.apama.util.TimestampSet
-
Adds or replaces the specified (index,time) pair in the underlying map
- putAll(Map<? extends String, ? extends String>) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Copies all of the mappings from the specified map to this map
These mappings will replace any mappings that
this map had for any of the keys currently in the specified map.
- putAll(Map<? extends Integer, ? extends Double>) - Method in class com.apama.util.TimestampSet
-
Copies all of the mappings from the specified map to this map
These mappings will replace any mappings that
this map had for any of the indices currently in the specified map.
- putIfAbsent(String, RowValue) - Method in class com.apama.correlator.memstore.AbstractTable
-
If the specified key is not already associated
with a value, associates it with the given value.
- putIfAbsent(String, RowValue) - Method in class com.apama.correlator.memstore.ConcurrentMapAdapter
-
- putNow(Integer) - Method in class com.apama.util.TimestampSet
-
Set the time of a specified timestamp in the timestamp set to current time, regardless of
whether a timestamp with the given index already exists.
- ReceiveConsumerOperationsInterface - Interface in com.apama.engine.beans.interfaces
-
ReceiveConsumerOperationsInterface is an interface providing the ability to create
consumers for receiving events from an Apama server component.
- ReconnectPolicyInterface - Interface in com.apama.engine.beans.interfaces
-
A policy that can be applied to an engine client to control
when it can reconnect.
- recordDownstream - Variable in class com.apama.iaf.plugin.TimestampConfig
-
Flag controlling recording of timestamps on downstream events.
- recordUpstream - Variable in class com.apama.iaf.plugin.TimestampConfig
-
Flag controlling recording of timestamps on upstream events.
- registerCloseHandlerForTable(AbstractTable) - Method in class com.apama.correlator.memstore.AbstractStore
-
Utility method that registers a newly created AbstractTable instance with
AbstractStore so that its close method is automatically called during the
store's close method.
- registerEventType(EventType) - Method in class com.apama.event.parser.EventParser
-
Register the given event type as being a valid type this parser
recognizes.
- registerEventType(EventType) - Method in interface com.apama.services.event.IEventServiceChannel
-
Register an arbitrary EventType with this EventServiceChannel.
- registerExtensions(ELMappingExtensionManager) - Method in interface com.apama.adapters.el.api.ELMappingExtensionProvider
-
Register EL methods and resolvers to mappingExtensionManager.
- registerMethod(String, Method) - Method in interface com.apama.adapters.el.api.ELMappingExtensionManager
-
Register the static method to mapping layer.
- registerResolver(ELResolver) - Method in interface com.apama.adapters.el.api.ELMappingExtensionManager
-
Register the resolver instance to mapping layer.
- releaseLock() - Method in interface com.apama.services.event.IResponseWrapper
-
Release any threads that are blocked due to having called waitOnLock().
- remove(String) - Method in class com.apama.correlator.memstore.AbstractTable
-
Removes the mapping for a key from this map if it is present.
- remove(String, RowValue) - Method in class com.apama.correlator.memstore.AbstractTable
-
Removes the entry for a key only if currently mapped to a given value.
- remove(String) - Method in class com.apama.correlator.memstore.ConcurrentMapAdapter
-
- remove(String, RowValue) - Method in class com.apama.correlator.memstore.ConcurrentMapAdapter
-
- remove(String) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Remove the named element from the normalised event.
- remove(Object) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Removes the mapping for this key from this map if present.
- remove(Object) - Method in class com.apama.util.TimestampSet
-
Removes the mapping for this index from this map if present.
- removeAll() - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Remove all elements from the normalised event.
- removeAllConsumers() - Method in class com.apama.engine.beans.EngineClientBean
-
Disconnect, Destroy, and Remove all existing consumers.
- removeAllConsumers() - Method in interface com.apama.engine.beans.interfaces.ReceiveConsumerOperationsInterface
-
Remove and disconnect all existing uniquely-named consumers.
- removeAllEventListeners() - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Remove all event listeners that are listening to this consumer.
- removeAllMatchListeners() - Method in class com.apama.jmon.EventExpression
-
Remove all previously registered match listeners.
- removeAllMatchListeners() - Method in class com.apama.jmon.PreparedEventExpression
-
Remove all previously registered match listeners.
- removeChannel(String) - Method in interface com.apama.services.event.IEventService
-
Remove an EventServiceChannel for a given channel or channels.
- removeClusterMembershipListener(ClusterMembershipListener) - Method in class com.apama.correlator.memstore.AbstractStore
-
Removes an existing cluster membership listener callback.
- removeColumnAt(int) - Method in interface com.apama.dashboard.data.ITabularData
-
Remove a column from a data table.
- removeConfiguration(int) - Method in interface com.apama.iaf.plugin.ConfigurableCodec
-
Remove configuration associated with the given id
- removeConsumer(String) - Method in class com.apama.engine.beans.EngineClientBean
-
Remove and disconnect an existing uniquely-named consumer.
- removeConsumer(String) - Method in interface com.apama.engine.beans.interfaces.ReceiveConsumerOperationsInterface
-
Remove and disconnect any existing uniquely-named consumer.
- removed(EventExpression) - Method in interface com.apama.jmon.RemoveListener
-
This method will be called whenever this Listener is removed from
an
EventExpression
it is attached to, or
when the event expression has moved into a state where it will
never match again e.g.
- removeEventDecoder(String) - Method in class com.apama.iaf.plugin.AbstractEventTransport
-
Remove a named event decoder from the set of decoders known to the
transport.
- removeEventListener(IEventListener) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Remove a previously added event listener.
- removeEventListener(IEventListener) - Method in interface com.apama.services.event.IEventServiceChannel
-
Remove a previously registered IEventListener that was listening to all
events received.
- removeEventListener(IEventListener, EventType) - Method in interface com.apama.services.event.IEventServiceChannel
-
Remove a previously registered IEventListener that was listening to all
events received of the specified EventType.
- removeEventTransport(String) - Method in class com.apama.iaf.plugin.AbstractEventCodec
-
Remove a named event transport from the set of transports known to the
codec.
- RemoveListener - Interface in com.apama.jmon
-
This interface defines the single method that must be implemented in order
for a
MatchListener
to be told when it's connection to an
EventExpression
has gone.
- removeListener(PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Remove a PropertyChangeListener that was to be notified of changes to any
bound property of this object.
- removeListener(String, PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Remove a PropertyChangeListener that was to be notified of changes to a
specific named bound property of this object.
- removeListener(PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioInstance
-
Remove a listener from the list of those interested in changes to any
object property, or scenario instance parameter.
- removeListener(String, PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioInstance
-
Remove a listener from the list of those interested in changes to the
object property with given name, or the scenario instance parameter with the given name.
- removeListener(PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioService
-
Remove a PropertyChangeListener that was to be notified of changes to any
bound property of this object.
- removeListener(String, PropertyChangeListener) - Method in interface com.apama.services.scenario.IScenarioService
-
Remove a PropertyChangeListener that was to be notified of changes to a
specific named bound property of this object.
- removeMatchListener(MatchListener) - Method in class com.apama.jmon.EventExpression
-
Remove a match listener that was previously registered.
- removePropertyChangeListener(PropertyChangeListener) - Method in class com.apama.engine.beans.EngineClientBean
-
- removePropertyChangeListener(String, PropertyChangeListener) - Method in class com.apama.engine.beans.EngineClientBean
-
- removePropertyChangeListener(PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Remove a property change listener.
- removePropertyChangeListener(String, PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Remove a property change listener for a specific named property.
- removePropertyChangeListener(PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Remove a property change listener.
- removePropertyChangeListener(String, PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Remove a property change listener for a specific named property.
- removePropertyChangeListener(PropertyChangeListener) - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Remove a property change listener.
- removePropertyChangeListener(String, PropertyChangeListener) - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Remove a property change listener for a specific named property.
- removePropertyChangeListener(PropertyChangeListener) - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Remove a property change listener.
- removePropertyChangeListener(String, PropertyChangeListener) - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Remove a property change listener for a specific named property.
- removePropertyChangeListener(PropertyChangeListener) - Method in class com.apama.net.beans.PingBean
-
Remove a property change listener.
- removePropertyChangeListener(String, PropertyChangeListener) - Method in class com.apama.net.beans.PingBean
-
Remove a property change listener for a specific named property.
- removePropertyChangeListener(String, PropertyChangeListener) - Method in interface com.apama.services.event.IEventService
-
Remove the property change listener for the specified property.
- removePropertyChangeListenerSync(PropertyChangeListener) - Method in class com.apama.engine.beans.EngineClientBean
-
- removePropertyChangeListenerSync(String, PropertyChangeListener) - Method in class com.apama.engine.beans.EngineClientBean
-
- removePropertyChangeListenerSync(PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Deprecated.
- removePropertyChangeListenerSync(String, PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Deprecated.
- removePropertyChangeListenerSync(PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Deprecated.
- removePropertyChangeListenerSync(String, PropertyChangeListener) - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Deprecated.
- removeRow(String) - Method in interface com.apama.dashboard.data.ITabularData
-
Remove a single row from a data table.
- removeRowAt(int) - Method in interface com.apama.dashboard.data.ITabularData
-
Remove a single row from a data table.
- removeRowChangedListener() - Method in class com.apama.correlator.memstore.notifications.RowChangedSubscriptionManager
-
Remove registration with the distributed table for row changed notifications.
- removeSubscription(long, long) - Method in class com.apama.correlator.memstore.notifications.RowChangedSubscriptionManager
-
Removes and closes this subscription so long as we are not shutting down.
- replace(String, RowValue, RowValue) - Method in class com.apama.correlator.memstore.AbstractTable
-
Replaces the entry for a key only if it is currently mapped to a given value.
- replace(String, RowValue, RowValue) - Method in class com.apama.correlator.memstore.ConcurrentMapAdapter
-
- replace(String, String) - Method in class com.apama.iaf.plugin.NormalisedEvent
-
- replace(Integer, Double) - Method in class com.apama.util.TimestampSet
-
- replaceWithNow(Integer) - Method in class com.apama.util.TimestampSet
-
- requestInstances() - Method in interface com.apama.services.scenario.IScenarioDefinition
-
Initiate requesting instances.
- requestResponse(Event, EventType) - Method in interface com.apama.services.event.IEventServiceChannel
-
Emulate a synchronous RPC call to the Correlator by sending an event and
awaiting a matching response event (blocking call).
- requestResponse(Event, EventType, long) - Method in interface com.apama.services.event.IEventServiceChannel
-
Emulate a synchronous RPC call to the Correlator by sending an event and
awaiting a matching response event (blocking call with timeout).
- ResponseTimeoutException - Exception in com.apama.services.event
-
ResponseTimeoutException is a specialized exception for use with the Event
Service that indicates that a request-response timeout has been exceeded.
- ResponseTimeoutException(String) - Constructor for exception com.apama.services.event.ResponseTimeoutException
-
- ResponseTimeoutException(String, Throwable) - Constructor for exception com.apama.services.event.ResponseTimeoutException
-
- ResponseTimeoutException(Throwable) - Constructor for exception com.apama.services.event.ResponseTimeoutException
-
- RETURN_TYPE_DOUBLE - Static variable in interface com.apama.dashboard.function.IFunctionDescriptor
-
Function returns an instance of Double
- RETURN_TYPE_INTEGER - Static variable in interface com.apama.dashboard.function.IFunctionDescriptor
-
Function returns an instance of Integer
- RETURN_TYPE_STRING - Static variable in interface com.apama.dashboard.function.IFunctionDescriptor
-
Function returns an instance of String
- RETURN_TYPE_TABLE - Static variable in interface com.apama.dashboard.function.IFunctionDescriptor
-
Function returns an instance of TabularData
- route() - Method in class com.apama.jmon.Event
-
Route this Event internally within the Correlator.
- RowChangedSubscriptionManager - Class in com.apama.correlator.memstore.notifications
-
A per-table helper object for managing each context's subscription to notifications about the table.
- RowChangedSubscriptionManager(String, String, String[]) - Constructor for class com.apama.correlator.memstore.notifications.RowChangedSubscriptionManager
-
Create a row changed subscription manager.
- RowChangedType - Enum in com.apama.correlator.memstore.notifications
-
Represents the supported types of row change alterations.
- RowKeyValueConverter<K,V> - Interface in com.apama.correlator.memstore
-
Interface to allow custom application-specific Java classes to be used to represent keys and values
instead of the default String (for keys) and RowValue classes.
- RowValue - Class in com.apama.correlator.memstore
-
The value of an entry/row in a distributed store's table.
- RowValue() - Constructor for class com.apama.correlator.memstore.RowValue
-
Default constructor for creating a new RowValue where the schema is not known.
- RowValueHelper - Class in com.apama.correlator.memstore
-
Helper class for more conveniently and efficiently
dealing with RowValue objects for a given table schema.
- RowValueHelper(String...) - Constructor for class com.apama.correlator.memstore.RowValueHelper
-
Create a new RowValueHelper based on the specified schema type information.
- ScenarioServiceConfig - Class in com.apama.services.scenario
-
ScenarioServiceConfig is a helper class that assists in building a properies map
for use when creating a new ScenarioService via the ScenarioServiceFactory.
- ScenarioServiceException - Exception in com.apama.services.scenario
-
ScenarioServiceException is a base exception class for all other specialized
exceptions within with the Scenario Service.
- ScenarioServiceException() - Constructor for exception com.apama.services.scenario.ScenarioServiceException
-
- ScenarioServiceException(String) - Constructor for exception com.apama.services.scenario.ScenarioServiceException
-
- ScenarioServiceException(String, Throwable) - Constructor for exception com.apama.services.scenario.ScenarioServiceException
-
- ScenarioServiceException(Throwable) - Constructor for exception com.apama.services.scenario.ScenarioServiceException
-
- ScenarioServiceFactory - Class in com.apama.services.scenario
-
ScenarioServiceFactory is a class that provides factory methods for creating
new instances of IScenarioService.
- SemanticMapper - Interface in com.apama.iaf.plugin
-
SemanticMapper defines the interface that Java IAF decoders implement so they
can be used by the IAF to convert a downstream event from the transport
into the normalised form required by the Semantic Mapper.
- SemanticMapperException - Exception in com.apama.iaf.plugin
-
SemanticMapperException is the exception class thrown by the IAF Semantic
Mapper.
- SemanticMapperException(String) - Constructor for exception com.apama.iaf.plugin.SemanticMapperException
-
Constructs a SemanticMapperException from a string message describing the
error, and assumes an error code of MAPPINGFAILURE.
- SemanticMapperException(String, int) - Constructor for exception com.apama.iaf.plugin.SemanticMapperException
-
Constructs a SemanticMapperException from a string message describing the
error and a numeric code representing the class of error.
- SemanticMapperException(String, Throwable) - Constructor for exception com.apama.iaf.plugin.SemanticMapperException
-
Constructs a SemanticMapperException from a string message describing the
error, and an exception object that is the cause of the error.
- SemanticMapperException(String, Throwable, int) - Constructor for exception com.apama.iaf.plugin.SemanticMapperException
-
Constructs a SemanticMapperException from a string message describing the
error, a numeric code representing the class of error and an exception
object that is the cause of the error.
- sendEvent(Event) - Method in interface com.apama.services.event.IEventService
-
Send an event to the Correlator using the EngineClient.
- sendEvents(boolean, Event...) - Method in class com.apama.engine.beans.EngineClientBean
-
Send events into the Engine, optionally not
performing auto-batching.
- sendEvents(Event...) - Method in class com.apama.engine.beans.EngineClientBean
-
- sendEvents(Event...) - Method in interface com.apama.engine.beans.interfaces.SendOperationsInterface
-
Send an array of Event objects to the engine (automatically rebatching the actual event sending for efficiency).
- sendEvents(boolean, Event...) - Method in interface com.apama.engine.beans.interfaces.SendOperationsInterface
-
Send events into the Engine, optionally not
performing rebatching the actual event sending.
- sendEvents(Event[]) - Method in interface com.apama.engine.EngineManagement
-
Send events into the Engine (inherited from EventConsumer),
automatically rebatching the actual event sending for efficiency.
- sendEvents(Event[]) - Method in interface com.apama.event.EventConsumer
-
This method must be defined in implementing classes to
enable receiving of events.
- sendEventsFromFile(List<String>, int) - Method in class com.apama.engine.beans.EngineClientBean
-
- sendEventsFromFile(List<String>, int, boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
- sendEventsFromFile(List<String>, int, boolean, boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
- sendEventsFromFile(List<String>, int, boolean, boolean, String) - Method in class com.apama.engine.beans.EngineClientBean
-
- sendEventsFromFile(List<String>, int) - Method in interface com.apama.engine.beans.interfaces.SendOperationsInterface
-
Send a number of events from a file or stdin.
- sendEventsFromFile(List<String>, int, boolean) - Method in interface com.apama.engine.beans.interfaces.SendOperationsInterface
-
Send a number of events from a file or stdin.
- sendEventsFromFile(List<String>, int, boolean, boolean) - Method in interface com.apama.engine.beans.interfaces.SendOperationsInterface
-
Send a number of events from a file or stdin, specifying the file
encoding detection mode and whether to auto-batch events or not.
- sendEventsFromFile(List<String>, int, boolean, boolean, String) - Method in interface com.apama.engine.beans.interfaces.SendOperationsInterface
-
Send a number of events from a file or stdin, specifying the file
encoding detection mode and whether to auto-batch events or not.
- sendEventsNoBatching(Event[]) - Method in interface com.apama.engine.EngineManagement
-
Send events into the Engine,
without rebatching the actual event sending.
- sendNormalisedEvent(NormalisedEvent, TimestampSet) - Method in class com.apama.iaf.plugin.AbstractEventCodec
-
- sendNormalisedEvent(NormalisedEvent, TimestampSet) - Method in interface com.apama.iaf.plugin.EventCodec
-
Called by the Semantic Mapper to encode a normalised event and send
it through to the transport.
- sendNormalisedEvent(NormalisedEvent, TimestampSet) - Method in interface com.apama.iaf.plugin.SemanticMapper
-
Called by the event codec to send a decoded event to the Semantic Mapper.
- SendOperationsInterface - Interface in com.apama.engine.beans.interfaces
-
SendOperationsInterface is an interface that specifies the standard operations to
enable an engine client to send events to a remote correlator.
- sendTo(String, Context) - Static method in class com.apama.epl.plugin.Correlator
-
Sends the supplied string to the specified context.
- sendTo(String, String) - Static method in class com.apama.epl.plugin.Correlator
-
Sends the supplied string to the specified channel name.
- 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 contexts.
- sendTransportEvent(Object, TimestampSet) - Method in class com.apama.iaf.plugin.AbstractEventCodec
-
- sendTransportEvent(Object, TimestampSet) - Method in class com.apama.iaf.plugin.AbstractEventTransport
-
- sendTransportEvent(Object, TimestampSet) - Method in interface com.apama.iaf.plugin.EventDecoder
-
Called by the event transport to decode a downstream event using a Java
Codec, which will then send it on to the Semantic Mapper.
- sendTransportEvent(Object, TimestampSet) - Method in interface com.apama.iaf.plugin.EventTransport
-
Called by an event encoder to send an upstream message to the external
transport.
- sequence(FieldType<E>) - Static method in class com.apama.event.parser.FieldTypes
-
Create a new field type object for an Apama sequence event field,
for which values are specified by objects implementing java.util.List<E>
.
- SequenceFieldType<E> - Class in com.apama.event.parser
-
Represents the Apama sequence<type>
type,
for which values are specified as List
objects.
- SequenceFieldType(FieldType<E>) - Constructor for class com.apama.event.parser.SequenceFieldType
-
Construct a new field type representing a sequence whose members are all of a given field type.
- SESSION_ID_FIELD - Static variable in interface com.apama.iaf.plugin.ConfigurableCodec
-
- setAckDataTimeout(Map<String, Object>, long) - Static method in class com.apama.services.scenario.ScenarioServiceConfig
-
Set the timeout for operations to wait for the Data channel to catch up.
- setAutoInstanceDiscovery(Map<String, Object>, boolean) - Static method in class com.apama.services.scenario.ScenarioServiceConfig
-
Set the boolean configuration property to indicate if the service should
discover instances automatically.
- setBackupCopies(int) - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
The number of additional redundant nodes that should hold a backup copy of each key/value data element.
- setBeanName(String) - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
Called by Spring to initialize the storeName using the id attribute in its configuration.
- setBoolean(int, boolean) - Method in class com.apama.correlator.memstore.RowValue
-
Set the n'th field of this type.
- setBoolean(int, int, boolean) - Method in class com.apama.correlator.memstore.RowValue
-
Deprecated.
- setBoolean(int, boolean) - Method in class com.apama.jmon.PreparedEventExpression
-
Set a Boolean type parameter in the PreparedEventExpression.
- setCancelDeleteFileRead(boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Setter for the cancelFileRead property for the Delete / Kill operations.
- setCancelDeleteFileRead(boolean) - Method in interface com.apama.engine.beans.interfaces.DeleteOperationsInterface
-
Setter for the cancelFileRead property for the Delete / Kill operations.
- setCancelInjectFileRead(boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Setter for the cancelFileRead property for the Inject operations.
- setCancelInjectFileRead(boolean) - Method in interface com.apama.engine.beans.interfaces.InjectOperationsInterface
-
Setter for the cancelFileRead property for the Inject operations.
- setCancelSendFileRead(boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Setter for the cancelFileRead property for the Send operations.
- setCancelSendFileRead(boolean) - Method in interface com.apama.engine.beans.interfaces.SendOperationsInterface
-
Setter for the cancelFileRead property for the Send operations.
- setCellValue(boolean, int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Set the value of a boolean cell in a data table.
- setCellValue(double, int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Set the value of a double cell in a data table.
- setCellValue(float, int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Set the value of a float cell in a data table.
- setCellValue(int, int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Set the value of an integer cell in a data table.
- setCellValue(long, int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Set the value of a long cell in a data table.
- setCellValue(String, int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Set the value of a string cell in a data table.
- setChannel(String) - Method in class com.apama.event.Event
-
Method to set the channel name for an event.
- setChannels(String[]) - Method in interface com.apama.engine.beans.interfaces.ConsumerOperationsInterface
-
Set the list of channel names to which this consumer is subscribed.
- setClusterName(String) - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
A provider-specific string used to group together distributed store nodes that communicate with each other and
share data.
- setConnectionPollingInterval(int) - Method in class com.apama.engine.beans.EngineClientBean
-
Set the polling interval (in milliseconds) for the background connection and ping thread.
- setConnectionPollingInterval(int) - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Set the polling interval (in milliseconds) for the internal connection
test thread.
- setConnectionPollingInterval(int) - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Set the polling interval (in milliseconds) for the internal connection test thread.
- setConnectionPollingInterval(int) - Method in class com.apama.net.beans.PingBean
-
Set the polling interval (in milliseconds) for the internal connection test thread.
- setDateCellValue(String, int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Set the value of a date cell in a data table.
- setDateCellValue(long, int, int) - Method in interface com.apama.dashboard.data.ITabularData
-
Set the value of a date cell in a data table.
- setDefaultRequestResponseTimeout(Map<String, Object>, long) - Static method in class com.apama.services.event.ChannelConfig
-
Set the configuration property to indicate the default request-response timeout that
a new EventServiceChannel should use.
- setDeliveryMode(Integer) - Method in class com.apama.correlator.jms.config.api.mapper.JmsSenderMessageHolder
-
Set the javax.jms.DeliveryMode override to use for this message.
- setDestination(Destination) - Method in class com.apama.correlator.jms.config.api.mapper.JmsSenderMessageHolder
-
Set the Destination this message should be sent to.
- setDisconnectIfSlow(boolean) - Method in interface com.apama.services.event.IEventService
-
Set the disconnect if slow property.
- setDisconnectIfSlow(Map<String, Object>, boolean) - Static method in class com.apama.services.scenario.ScenarioServiceConfig
-
Set the boolean configuration property to indicate if our event receiver
should be disconnected if slow.
- setDouble(int, double) - Method in class com.apama.jmon.PreparedEventExpression
-
Set a double type parameter in the PreparedEventExpression.
- setEnforceResponseSequencing(Map<String, Object>, boolean) - Static method in class com.apama.services.event.ChannelConfig
-
Set the configuration property to indicate if a new EventServiceChannel should use
strict response sequencing for synchronous request-response invocations.
- setEventParser(EventParser) - Method in class com.apama.event.Event
-
Method to set a user-provided EventParser.
- setField(String, Object) - Method in class com.apama.event.Event
-
Set the value of a field in this event instance.
- setField(Field<T>, T) - Method in class com.apama.event.Event
-
Set the value of a field in this event instance.
- setField(String, FieldType<T>, T) - Method in class com.apama.event.Event
-
Set the value of a field in this event instance.
- setFloat(int, double) - Method in class com.apama.correlator.memstore.RowValue
-
Set the n'th field of this type.
- setFloat(int, int, double) - Method in class com.apama.correlator.memstore.RowValue
-
Deprecated.
- setHost(String) - Method in class com.apama.engine.beans.EngineClientBean
-
Setter for the host property.
- setHost(String) - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Setter for the host property.
- setHost(String) - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Setter for the host property.
- setHost(String) - Method in class com.apama.net.beans.PingBean
-
Setter for the host property.
- setInboundEventQueueSoftReferencePrefixes(Map<String, Object>, Set<String>) - Static method in class com.apama.services.event.ChannelConfig
-
Set the configuration property to indicate for which event names a new
EventServiceChannel should use SoftReferences in the inbound queue.
- setInitialMinClusterSize(int) - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
The minimum number of nodes that are required to join the cluster before the Distributed MemoryStore
will send the Finished event.
- setInspectPollingInterval(int) - Method in class com.apama.engine.beans.EngineClientBean
-
Set the inspectPollingInterval (in milliseconds) that the background thread should wait
between calls for new information.
- setInspectPollingInterval(int) - Method in interface com.apama.engine.beans.interfaces.InspectOperationsInterface
-
Set the inspectPollingInterval (in milliseconds) that the background thread should wait
between calls for new information.
- setInteger(int, long) - Method in class com.apama.correlator.memstore.RowValue
-
Set the n'th field of this type.
- setInteger(int, int, long) - Method in class com.apama.correlator.memstore.RowValue
-
Deprecated.
- setJmsMessage(Message) - Method in class com.apama.correlator.jms.config.api.mapper.JmsSenderMessageHolder
-
- setLateResponseListener(IEventListener) - Method in interface com.apama.services.event.IEventServiceChannel
-
Register the single IEventListener that will be notified of any "late"
responses to either synchronous or asynchronous request-response calls.
- setLocalVariable(String, String) - Method in interface com.apama.dashboard.IDashboardContext
-
Set a single local variable value.
- setLocation(int, Location) - Method in class com.apama.jmon.PreparedEventExpression
-
Set a Location type parameter in the PreparedEventExpression.
- setLogLevel(String) - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
The Apama log level at which this provider should log its own messages (not all providers will support this).
- setLogLevel(GenericComponentManagement.GenericComponentLogLevel) - Method in class com.apama.net.beans.GenericComponentManagementBean
-
- setLogLevel(GenericComponentManagement.GenericComponentLogLevel) - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Set the component's logging level
- setLogLevel(GenericComponentManagement.GenericComponentLogLevel) - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Set the component's logging level
- setLong(int, long) - Method in class com.apama.jmon.PreparedEventExpression
-
Set a long type parameter in the PreparedEventExpression.
- setMessageIdFieldName(Map<String, Object>, String) - Static method in class com.apama.services.event.ChannelConfig
-
Set the configuration property to indicate the field name of message ID's (for
request-response) that a new EventServiceChannel should use.
- setMonitorOnly(boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Setter for the monitorOnly property.
- setPersistentReceiveConnections(EngineConnection...) - Method in class com.apama.engine.beans.EngineClientBean
-
Attaches this component as a persistent receiver of the remote
components specified in the connections argument, then decrements the
reference count of any existing connections (which typically results in
their removal).
- setPersistentReceiveConnections(EngineConnection...) - Method in interface com.apama.engine.beans.interfaces.ConnectOperationsInterface
-
Attaches this component as a persistent receiver of the remote
components specified in the connections argument, then decrements the
reference count of any existing connections (which typically results in
their removal).
- setPersistentReceiveConnections(EngineConnection...) - Method in interface com.apama.engine.EngineManagement
-
Attaches this component as a persistent receiver of the remote
components specified in the connections argument, then decrements the
reference count of any existing connections (which typically results in
their removal).
- setPort(int) - Method in class com.apama.engine.beans.EngineClientBean
-
Setter for the port property.
- setPort(int) - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Setter for the port property.
- setPort(int) - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Setter for the port property.
- setPort(int) - Method in class com.apama.net.beans.PingBean
-
Setter for the port property.
- setPriority(Integer) - Method in class com.apama.correlator.jms.config.api.mapper.JmsSenderMessageHolder
-
Set the JMS message priority.
- setProcessName(String) - Method in class com.apama.engine.beans.EngineClientBean
-
Setter for the process Name
This is the process name property to use.
- setProcessName(String) - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Setter for the process name property.
- setProcessName(String) - Method in interface com.apama.net.beans.interfaces.BaseClientInterface
-
Setter for the process name property.
- setProcessName(String) - Method in class com.apama.net.beans.PingBean
-
Setter for the process Name
This is the process name property to use
Changing this property will cause any existing connection to be lost.
- setReceiveOnly(boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Setter for the receiveOnly property.
- setReceiverMapperDelegate(JmsReceiverMapperFactory) - Method in class com.apama.correlator.jms.config.api.mapper.SimpleAbstractJmsMessageMapper
-
The optional receiverMapperDelegate bean property specifies the factory of a receiver mapper which
should be used for any messages not handled directly by this mapper.
- setReconnectPeriod(long) - Method in class com.apama.engine.beans.EngineClientBean
-
- setReconnectPeriod(long) - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Set the minimum period between attempts to reconnect the bean
and/or any of the bean's named consumers that have been disconnected (e.g.
- setReconnectPeriod(Map<String, Object>, long) - Static method in class com.apama.services.scenario.ScenarioServiceConfig
-
Set the float configuration property to indicate how long to wait between
reconections
- setReconnectPolicy(ReconnectPolicyInterface) - Method in class com.apama.engine.beans.EngineClientBean
-
- setReconnectPolicy(ReconnectPolicyInterface) - Method in interface com.apama.engine.beans.interfaces.EngineClientInterface
-
Set a singleton reconnection policy that will be used to limit when reconnection can be attempted
for the bean, and/or any of the bean's named consumers that have been disconnected (e.g.
- setRowChangedOldValueRequired(boolean) - Method in class com.apama.correlator.memstore.AbstractStoreFactory
-
Set whether subscribers should receive old values in RowChanged events.
- setScenarioExclusionFilter(Map<String, Object>, Set<String>) - Static method in class com.apama.services.scenario.ScenarioServiceConfig
-
Set the configuration property to the Set of ScenarioID's that the
client wishes to ignore.
- setScenarioInclusionFilter(Map<String, Object>, Set<String>) - Static method in class com.apama.services.scenario.ScenarioServiceConfig
-
Set the configuration property to the Set of ScenarioID's in which the
client is interested.
- setSemanticMapper(SemanticMapper) - Method in class com.apama.iaf.plugin.AbstractEventCodec
-
Set the Semantic Mapper object to be used by the decoder.
- setSenderMapperDelegate(JmsSenderMapperFactory) - Method in class com.apama.correlator.jms.config.api.mapper.SimpleAbstractJmsMessageMapper
-
The optional senderMapperDelegate bean property specifies the factory of a sender mapper which
should be used for any events not handled directly by this mapper.
- setStatusPollingInterval(int) - Method in class com.apama.engine.beans.EngineClientBean
-
Set the statusPollingInterval (in milliseconds) that the background thread should wait
between calls for new status information.
- setStatusPollingInterval(int) - Method in interface com.apama.engine.beans.interfaces.WatchOperationsInterface
-
Set the statusPollingInterval (in milliseconds) that the background thread should wait
between calls for new status information.
- setString(int, String) - Method in class com.apama.correlator.memstore.RowValue
-
Set the n'th string field.
- setString(int, int, String) - Method in class com.apama.correlator.memstore.RowValue
-
Deprecated.
- setString(int, int, byte[]) - Method in class com.apama.correlator.memstore.RowValue
-
Deprecated.
- setString(int, String) - Method in class com.apama.jmon.PreparedEventExpression
-
Set a string type parameter in the PreparedEventExpression.
- setStringBytes(int, byte[]) - Method in class com.apama.correlator.memstore.RowValue
-
Set the n'th string field from a UTF-8 null-terminated byte array
(which is currently the in-memory storage format for strings).
- setStrongDataInboundEventQueue(Map<String, Object>, boolean) - Static method in class com.apama.services.scenario.ScenarioServiceConfig
-
Set the boolean configuration property to indicate if the 'Data' channels
(EventServiceChannel's), created for listening to scenario instance
output variable updates, should use strong or soft references to
events in the inbound event queue.
- setSubstitution(String, String, boolean) - Method in interface com.apama.dashboard.IDashboardContext
-
Set the value of a single dashboard substitution.
- setSubstitutions(Vector<String>, Vector<String>, boolean) - Method in interface com.apama.dashboard.IDashboardContext
-
Set multiple dashboard substitutions.
- setThreshold(String) - Method in class com.apama.util.Logger
-
Sets the logging threshold for this instance of Logger.
- setTime(double) - Method in class com.apama.event.Event
-
Method to set the timestamp for the event.
- setTimeToLive(Long) - Method in class com.apama.correlator.jms.config.api.mapper.JmsSenderMessageHolder
-
Set the time to live for this message in milliseconds.
- setUseRawDataChannel(Map<String, Object>, boolean) - Static method in class com.apama.services.scenario.ScenarioServiceConfig
-
Set the boolean configuration property to indicate if the 'Data' channels
(EventServiceChannel's), created for listening to scenario instance
output variable updates, should be subscribed to the normal Data channel
(possibly throttled), or the Raw Data channel (always unthrottled).
- setUsernameFilter(Map<String, Object>, String) - Static method in class com.apama.services.scenario.ScenarioServiceConfig
-
Set the configuration property to filter by a given user
If present, the scenario(s) listened for must have the ConfigureUpdates
property sendRawUser or sendThrottledUser set to true.
- setValue(String, Object) - Method in interface com.apama.services.scenario.IScenarioInstance
-
Set the value of a single specific (input) parameter of this instance.
- setValues(Map<String, Object>) - Method in interface com.apama.services.scenario.IScenarioInstance
-
Set several (input) parameter values of this instance.
- setVerbose(boolean) - Method in class com.apama.engine.beans.EngineClientBean
-
Setter for the verbose property.
- setVerbose(boolean) - Method in class com.apama.net.beans.AbstractGenericComponentManagementBean
-
Setter for the verbose property.
- shutdown() - Method in class com.apama.correlator.memstore.notifications.RowChangedSubscriptionManager
-
Shuts the subscription manager down.
- shutdown(String) - Method in class com.apama.net.beans.GenericComponentManagementBean
-
Tell the remote server to shut itself down.
- shutdown(String) - Method in interface com.apama.net.beans.interfaces.GenericComponentManagementOperationsInterface
-
Tell the component to shut itself down NOW
- shutdown(String) - Method in interface com.apama.net.interfaces.GenericComponentManagement
-
Tell the component to shut itself down NOW
- shutdown() - Static method in class com.apama.util.Logger
-
Performs any necessary cleanup for this logger.
- SimpleAbstractJmsMessageMapper - Class in com.apama.correlator.jms.config.api.mapper
-
Abstract helper class for implementing simple mappings
between JMS messages and Apama events, with optional support for delegation to another mapper.
- SimpleAbstractJmsMessageMapper() - Constructor for class com.apama.correlator.jms.config.api.mapper.SimpleAbstractJmsMessageMapper
-
- size() - Method in class com.apama.correlator.memstore.AbstractTable
-
Returns the number of key-value mappings in this map.
- size() - Method in class com.apama.correlator.memstore.ConcurrentMapAdapter
-
- size() - Method in class com.apama.iaf.plugin.NormalisedEvent
-
Get the number of elements (name-value pairs) currently stored by the
event.
- size() - Method in class com.apama.util.TimestampSet
-
Get the number of elements (name-time pairs) currently stored by the
event.
- sortRows() - Method in interface com.apama.dashboard.data.ITabularData
-
Sort the rows in a data table.
- start() - Method in class com.apama.iaf.plugin.AbstractEventTransport
-
Establish a connection and start processing incoming data from the
external transport.
- startInspectPollingThread() - Method in class com.apama.engine.beans.EngineClientBean
-
Start the local inspect polling thread.
- startInspectPollingThread() - Method in interface com.apama.engine.beans.interfaces.InspectOperationsInterface
-
Start the local inspect polling thread.
- startStatusPollingThread() - Method in class com.apama.engine.beans.EngineClientBean
-
Start the local status polling thread.
- startStatusPollingThread() - Method in interface com.apama.engine.beans.interfaces.WatchOperationsInterface
-
Start the local status polling thread.
- stop() - Method in class com.apama.iaf.plugin.AbstractEventTransport
-
Stop processing incoming data from the external transport, typically
by pausing or closing down connections.
- stopInspectPollingThread() - Method in class com.apama.engine.beans.EngineClientBean
-
Stop the local inspect polling thread.
- stopInspectPollingThread() - Method in interface com.apama.engine.beans.interfaces.InspectOperationsInterface
-
Stop the local inspect polling thread.
- stopStatusPollingThread() - Method in class com.apama.engine.beans.EngineClientBean
-
Stop the local status polling thread.
- stopStatusPollingThread() - Method in interface com.apama.engine.beans.interfaces.WatchOperationsInterface
-
Stop the local status polling thread.
- STRING - Static variable in class com.apama.event.parser.FieldTypes
-
Get the singleton field type object for the Apama string type,
for which values are specified as Java String
objects.
- StringFieldType - Class in com.apama.event.parser
-
Represents the Apama string
type,
for which values are specified as String
objects.
- stringToDestination(String) - Method in interface com.apama.correlator.jms.config.api.mapper.JmsSenderMapperContext
-
Converts the specified Apama-specific string representation of a queue or topic into a JMS Destination object,
perhaps performing a JNDI lookup if required.
- subscribe(EventHandler, String...) - Static method in class com.apama.epl.plugin.Correlator
-
Subscribes a callback handler for events sent to the given channels.
- SYSPROP_FILTER_USER - Static variable in interface com.apama.services.scenario.IScenarioService
-
system property specifying whether to only list to updates
for the specified user
If present, the scenario(s) listened for must have the ConfigureUpdates
property sendRawUser or sendThrottledUser set to true.