com.espertech.esper.client.dataflow
Interface EventBusCollector

public interface EventBusCollector

Collector for send events into the event bus.

Method Summary

void	sendEvent(java.util.Map map, java.lang.String eventTypeName) Send a map containing event property values to the event stream processing runtime.
void	sendEvent(org.w3c.dom.Node node) Send an event represented by a DOM node to the event stream processing runtime.
void	sendEvent(java.lang.Object object) Send an event represented by a plain Java object to the event stream processing runtime.
void	sendEvent(java.lang.Object[] objectArray, java.lang.String eventTypeName) Send an object array containing event property values as array elements to the event stream processing runtime.

Method Detail

sendEvent

void sendEvent(java.lang.Object object)
               throws EPException

Send an event represented by a plain Java object to the event stream processing 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.

Parameters:

object - is the event to sent to the runtime

Throws:

EPException - is thrown when the processing of the event lead to an error

sendEvent

void sendEvent(java.util.Map map,
               java.lang.String eventTypeName)
               throws EPException

Send a map containing event property values to the event stream processing 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.

Parameters:

map - - 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 - - the name for the Map event type that was previously configured

Throws:

EPException - - when the processing of the event leads to an error

sendEvent

void sendEvent(java.lang.Object[] objectArray,
               java.lang.String eventTypeName)
               throws EPException

Send an object array containing event property values as array elements to the event stream processing 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.

Parameters:

objectArray - - object 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 - - the name for the Object-array event type that was previously configured

Throws:

EPException - - when the processing of the event leads to an error

sendEvent

void sendEvent(org.w3c.dom.Node node)
               throws EPException

Send an event represented by a DOM node to the event stream processing 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.

Parameters:

node - is the DOM node as an event

Throws:

EPException - is thrown when the processing of the event lead to an error