Package com.espertech.esper.runtime.client

Interface EPEventServiceRouteEvent

All Known Subinterfaces:
EPEventService, EPStageEventService
public interface EPEventServiceRouteEvent
Service for processing events that originate from listeners, subscribers or other extension code.

  • Method Summary

    Modifier and Type
    Method
    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
    routeEventJson(String 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 Details

    • 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

    • routeEventJson

      void routeEventJson(String 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