com.espertech.esper.runtime.client

Interface EPEventServiceRouteEvent

All Known Subinterfaces:

EPEventService, EPEventServiceSPI

All Known Implementing Classes:

EPEventServiceImpl

public interface EPEventServiceRouteEvent

Service for processing events that originate from listeners, subscribers or other extension code.

Method Summary

Modifier and Type	Method and Description
void	routeEventAvro(Object avroGenericDataDotRecord, String eventTypeName) 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.
void	routeEventBean(Object event, String eventTypeName) 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.
void	routeEventMap(Map<String,Object> event, String eventTypeName) 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.
void	routeEventObjectArray(Object[] event, String eventTypeName) 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.
void	routeEventXMLDOM(Node event, String eventTypeName) 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.

Method Detail

routeEventObjectArray

void routeEventObjectArray(Object[] event,
                           String eventTypeName)

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.

Parameters:

event - to route internally for processing by the runtime

eventTypeName - event type name

routeEventBean

void routeEventBean(Object event,
                    String eventTypeName)

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.

Parameters:

event - to route internally for processing by the runtime

eventTypeName - event type name

routeEventMap

void routeEventMap(Map<String,Object> event,
                   String eventTypeName)

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.

Parameters:

event - to route internally for processing by the runtime

eventTypeName - event type name

routeEventXMLDOM

void routeEventXMLDOM(Node event,
                      String eventTypeName)

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.

Parameters:

event - to route internally for processing by the runtime

eventTypeName - event type name

routeEventAvro

void routeEventAvro(Object avroGenericDataDotRecord,
                    String eventTypeName)

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.

Parameters:

avroGenericDataDotRecord - to route internally for processing by the runtime

eventTypeName - event type name