com.espertech.esper.event
Class EventSenderImpl

java.lang.Object
  com.espertech.esper.event.EventSenderImpl

All Implemented Interfaces:

EventSender

public class EventSenderImpl
extends java.lang.Object
implements EventSender

Event sender for use with plug-in event representations.

The implementation asks a list of event bean factoryies originating from plug-in event representations to each reflect on the event and generate an event bean. The first one to return an event bean wins.

Constructor Summary

EventSenderImpl(java.util.List<EventSenderURIDesc> handlingFactories, EPRuntimeEventSender epRuntime, ThreadingService threadingService)
Ctor.

Method Summary

void	route(java.lang.Object theEvent) Route the event object back to the event stream processing runtime for internal dispatching, to avoid the possibility of a stack overflow due to nested calls to sendEvent.
void	sendEvent(java.lang.Object theEvent) Processes the event object.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

EventSenderImpl

public EventSenderImpl(java.util.List<EventSenderURIDesc> handlingFactories,
                       EPRuntimeEventSender epRuntime,
                       ThreadingService threadingService)

Ctor.

Parameters:

handlingFactories - list of factories

epRuntime - the runtime to use to process the event

threadingService - for inbound threading

Method Detail

sendEvent

public void sendEvent(java.lang.Object theEvent)
               throws EPException

Description copied from interface: EventSender

Processes the event object.

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.

Specified by:

sendEvent in interface EventSender

Parameters:

theEvent - to process

Throws:

EPException - if a runtime error occured.

route

public void route(java.lang.Object theEvent)
           throws EPException

Description copied from interface: EventSender

Route the event object back to the event stream processing 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 through the EPRuntime.sendEvent method.

Specified by:

route in interface EventSender

Parameters:

theEvent - to process

Throws:

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