Package com.espertech.esper.common.internal.event.json.compiletime

Class EventSenderJsonImpl

java.lang.Object

com.espertech.esper.common.internal.event.json.compiletime.EventSenderJsonImpl

All Implemented Interfaces:

EventSender, EventSenderJson

public class EventSenderJsonImpl
extends Object
implements EventSenderJson

Event sender for json-backed events.

Allows sending only event objects of type string, does not check contents. Any other event object generates an error.

Constructor Summary

Constructors

Constructor	Description
EventSenderJsonImpl(EPRuntimeEventProcessWrapped runtimeEventSender, JsonEventType eventType, EventBeanTypedEventFactory eventBeanTypedEventFactory, ThreadingCommon threadingService)	Ctor.

Method Summary

Modifier and Type	Method	Description
Object	parse(String json)
void	routeEvent(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(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 Details

EventSenderJsonImpl

public EventSenderJsonImpl(EPRuntimeEventProcessWrapped runtimeEventSender,
 JsonEventType eventType,
 EventBeanTypedEventFactory eventBeanTypedEventFactory,
 ThreadingCommon threadingService)

Ctor.

Parameters:

runtimeEventSender - for processing events

eventType - the event type

threadingService - for inbound threading

eventBeanTypedEventFactory - for event bean creation

Method Details

sendEvent

public void sendEvent(Object theEvent)

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

routeEvent

public void routeEvent(Object theEvent)

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:

routeEvent in interface EventSender

Parameters:

theEvent - to process

parse

public Object parse(String json)

Specified by:

parse in interface EventSenderJson

Parameters:

json - to parse

Returns:

event object