Package com.espertech.esper.runtime.client

Interface EPEventServiceSendEvent

All Known Subinterfaces:
EPEventService, EPStageEventService
public interface EPEventServiceSendEvent
Service for processing events.

Use any of the route-event methods of EPEventServiceRouteEvent when listeners, subscribers or extension code process events.

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    sendEventAvro(Object avroGenericDataDotRecord, String avroEventTypeName)
    Send an event represented by a Avro GenericData.Record to the runtime.
    void
    sendEventBean(Object event, String eventTypeName)
    Send an event represented by an object to the runtime.
    void
    sendEventJson(String json, String jsonEventTypeName)
    Send an event represented by a String JSON to the runtime.
    void
    sendEventMap(Map<String,Object> event, String eventTypeName)
    Send a map containing event property values to the runtime.
    void
    sendEventObjectArray(Object[] event, String eventTypeName)
    Send an object array containing event property values to the runtime.
    void
    sendEventXMLDOM(Node node, String eventTypeName)
    Send an event represented by a DOM node to the runtime.

  • Method Details

    • sendEventObjectArray

      void sendEventObjectArray(Object[] event, String eventTypeName)
      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 EPEventServiceRouteEvent.routeEventObjectArray(Object[], String).

      Parameters:
      event - - array that contains event property values. Your application must ensure that property values match the exact same order that the property names and types have been declared, and that the array length matches the number of properties declared.
      eventTypeName - - event type name
      Throws:
      EPException - - when the processing of the event leads to an error

    • sendEventBean

      void sendEventBean(Object event, String eventTypeName)
      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 EPEventServiceRouteEvent.routeEventBean(Object, String).

      Parameters:
      event - is the event to sent to the runtime
      eventTypeName - event type name
      Throws:
      EPException - is thrown when the processing of the event lead to an error

    • sendEventMap

      void sendEventMap(Map<String,Object> event, String eventTypeName)
      Send a map 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 EPEventServiceRouteEvent.routeEventMap(java.util.Map, String)).

      Parameters:
      event - - map that contains event property values. Keys are expected to be of type String while values can be of any type. Keys and values should match those declared via Configuration for the given eventTypeName.
      eventTypeName - - event type name
      Throws:
      EPException - - when the processing of the event leads to an error

    • sendEventXMLDOM

      void sendEventXMLDOM(Node node, String eventTypeName)
      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 EPEventServiceRouteEvent.routeEventXMLDOM(Node, String).

      Parameters:
      node - is the DOM node as an event
      eventTypeName - event type name
      Throws:
      EPException - is thrown when the processing of the event lead to an error

    • sendEventAvro

      void sendEventAvro(Object avroGenericDataDotRecord, String avroEventTypeName)
      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 EPEventServiceRouteEvent.routeEventAvro(Object, String)}).

      Parameters:
      avroGenericDataDotRecord - is the event to sent to the runtime
      avroEventTypeName - event type name
      Throws:
      EPException - is thrown when the processing of the event lead to an error

    • sendEventJson

      void sendEventJson(String json, String jsonEventTypeName)
      Send an event represented by a String JSON 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 EPEventServiceRouteEvent.routeEventJson(String, String)}).

      Parameters:
      json - is the event to sent to the runtime
      jsonEventTypeName - event type name
      Throws:
      EPException - is thrown when the processing of the event lead to an error, including for Json parsing problems