Click or drag to resize

EPEventService Methods

The EPEventService type exposes the following members.

Methods
  NameDescription
Public methodAdvanceTime
Advance time by jumping to the given time in milliseconds (or nanoseconds if so configured).

For externally controlling the time within a runtime.

External clocking must be first be enabled by configuration {@link com.espertech.esper.common.client.configuration.Runtime.ConfigurationRuntimeThreading.IsInternalTimerEnabled} passing false or by calling {@link #clockExternal()}.

Time should never move backwards (unless for testing purposes where previous results can be thrown away)

(Inherited from EPEventServiceTimeControl.)
Public methodAdvanceTimeSpan(Int64)
Advance time by continually-sliding to the given time in milliseconds (or nanoseconds if so configured) at the smallest resolution (non-hopping).

For externally controlling the time within a runtime.

External clocking must be first be enabled by configuration {@link com.espertech.esper.common.client.configuration.Runtime.ConfigurationRuntimeThreading.IsInternalTimerEnabled} passing false or by calling {@link #clockExternal()}.

Time should never move backwards (unless for testing purposes where previous results can be thrown away)

(Inherited from EPEventServiceTimeControl.)
Public methodAdvanceTimeSpan(Int64, Int64)
Advance time by continually-sliding to the given time in milliseconds (or nanoseconds if so configured) at the provided resolution (hopping).

For externally controlling the time within a runtime.

External clocking must be first be enabled by configuration {@link com.espertech.esper.common.client.configuration.Runtime.ConfigurationRuntimeThreading.IsInternalTimerEnabled} passing false or by calling {@link #clockExternal()}.

Time should never move backwards (unless for testing purposes where previous results can be thrown away)

(Inherited from EPEventServiceTimeControl.)
Public methodClockExternal
Switches off the internal timer which tracks system time. There is no effect if the runtime is already on external internal time.

Your application may want to use {@link #advanceTime(long)}, {@link #advanceTimeSpan(long)} or {@link #advanceTimeSpan(long, long)} after calling this method to set or advance time.

Its generally preferable to turn off internal clocking (and thus turn on external clocking) by configuration {@link com.espertech.esper.common.client.configuration.Runtime.ConfigurationRuntimeThreading.IsInternalTimerEnabled} passing false.

(Inherited from EPEventServiceTimeControl.)
Public methodClockInternal
Switches on the internal timer which tracks system time. There is no effect if the runtime is already on internal time.

Your application may not want to use {@link #advanceTime(long)}, {@link #advanceTimeSpan(long)} or {@link #advanceTimeSpan(long, long)} after calling this method, since time advances according to JVM time.

(Inherited from EPEventServiceTimeControl.)
Public methodGetEventSender
Returns a facility to process event objects that are of a known type.

Given an event type name this method returns a sender that allows to send in event objects of that type. The event objects send in via the event sender are expected to match the event type, thus the event sender does not inspect the event object other then perform basic checking.

For events backed by a Java class (JavaBean events), the sender ensures that the object send in matches in class, or implements or extends the class underlying the event type for the given event type name. Note that event type identity for Java class events is the Java class. When assigning two different event type names to the same Java class the names are an alias for the same event type i.e. there is always a single event type to represent a given Java class.

For events backed by a Object[] (Object-array events), the sender does not perform any checking other then checking that the event object indeed is an array of object.

For events backed by a IDictionary (Map events), the sender does not perform any checking other then checking that the event object indeed implements Map.

For events backed by a org.w3c.Node (XML DOM events), the sender checks that the root element name indeed does match the root element name for the event type name.

Public methodIsExternalClockingEnabled
Returns true for external clocking, false for internal clocking.
(Inherited from EPEventServiceTimeControl.)
Public methodResetStats
Reset the count of the number of events received and emitted
Public methodRouteEventAvro
Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent. The route event is processed just like it was sent to the runtime, that is any active expressions seeking that event receive it. The routed event has priority over other events sent to the runtime. In a single-threaded application the routed event is processed before the next event is sent to the runtime.

Note: when outbound-threading is enabled, the thread delivering to listeners is not the thread processing the original event. Therefore with outbound-threading enabled the sendEvent method should be used by listeners instead.

(Inherited from EPEventServiceRouteEvent.)
Public methodRouteEventBean
Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent. The route event is processed just like it was sent to the runtime, that is any active expressions seeking that event receive it. The routed event has priority over other events sent to the runtime. In a single-threaded application the routed event is processed before the next event is sent to the runtime.

Note: when outbound-threading is enabled, the thread delivering to listeners is not the thread processing the original event. Therefore with outbound-threading enabled the sendEvent method should be used by listeners instead.

(Inherited from EPEventServiceRouteEvent.)
Public methodRouteEventMap (Inherited from EPEventServiceRouteEvent.)
Public methodRouteEventObjectArray
Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent. The route event is processed just like it was sent to the runtime, that is any active expressions seeking that event receive it. The routed event has priority over other events sent to the runtime. In a single-threaded application the routed event is processed before the next event is sent to the runtime.

Note: when outbound-threading is enabled, the thread delivering to listeners is not the thread processing the original event. Therefore with outbound-threading enabled the sendEvent method should be used by listeners instead.

(Inherited from EPEventServiceRouteEvent.)
Public methodRouteEventXMLDOM
Route the event object back to the runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent. The route event is processed just like it was sent to the runtime, that is any active expressions seeking that event receive it. The routed event has priority over other events sent to the runtime. In a single-threaded application the routed event is processed before the next event is sent to the runtime.

Note: when outbound-threading is enabled, the thread delivering to listeners is not the thread processing the original event. Therefore with outbound-threading enabled the sendEvent method should be used by listeners instead.

(Inherited from EPEventServiceRouteEvent.)
Public methodSendEventAvro
Send an event represented by a Avro GenericData.Record to the runtime.

Use the route method for sending events into the runtime from within UpdateListener code, to avoid the possibility of a stack overflow due to nested calls to sendEvent (except with the outbound-threading configuration), see {@link EPEventServiceRouteEvent#routeEventAvro(Object, String)}}).

(Inherited from EPEventServiceSendEvent.)
Public methodSendEventBean
Send an event represented by an object to the runtime.

Use the route method for sending events into the runtime from within UpdateListener code, to avoid the possibility of a stack overflow due to nested calls to sendEvent (except with the outbound-threading configuration), see {@link EPEventServiceRouteEvent#routeEventBean(Object, String)}.

(Inherited from EPEventServiceSendEvent.)
Public methodSendEventMap (Inherited from EPEventServiceSendEvent.)
Public methodSendEventObjectArray
Send an object array containing event property values to the runtime.

Use the route method for sending events into the runtime from within UpdateListener code. to avoid the possibility of a stack overflow due to nested calls to sendEvent (except with the outbound-threading configuration), see {@link EPEventServiceRouteEvent#routeEventObjectArray(Object[], String)}.

(Inherited from EPEventServiceSendEvent.)
Public methodSendEventXMLDOM
Send an event represented by a DOM node to the runtime.

Use the route method for sending events into the runtime from within UpdateListener code. to avoid the possibility of a stack overflow due to nested calls to sendEvent (except with the outbound-threading configuration), see {@link EPEventServiceRouteEvent#routeEventXMLDOM(Node, String)}.

(Inherited from EPEventServiceSendEvent.)
Top
See Also