com.espertech.esper.common.internal.context.util

Class InternalEventRouterImpl

java.lang.Object

com.espertech.esper.common.internal.context.util.InternalEventRouterImpl

All Implemented Interfaces:

InternalEventRouter

public class InternalEventRouterImpl
extends Object
implements InternalEventRouter

Routing implementation that allows to pre-process events.

Constructor Summary

Constructors

Constructor and Description
InternalEventRouterImpl(EventBeanTypedEventFactory eventBeanTypedEventFactory)

Method Summary

Modifier and Type	Method and Description
void	addPreprocessing(InternalEventRouterDesc internalEventRouterDesc, InternalRoutePreprocessView outputView, StatementAgentInstanceLock agentInstanceLock, boolean hasSubselect)
boolean	isHasPreprocessing() Return true to indicate that there is pre-processing to take place.
EventBean	preprocess(EventBean theEvent, ExprEvaluatorContext runtimeFilterAndDispatchTimeContext, InstrumentationCommon instrumentation) Pre-process the event.
void	removePreprocessing(EventType eventType, InternalEventRouterDesc desc)
void	route(EventBean theEvent, AgentInstanceContext agentInstanceContext, boolean addToFront) Route the event such that the event is processed as required.
void	route(EventBean theEvent, EPStatementHandle statementHandle, InternalEventRouteDest routeDest, ExprEvaluatorContext exprEvaluatorContext, boolean addToFront)
void	setInsertIntoListener(InsertIntoListener insertIntoListener)

Methods inherited from class java.lang.Object

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

Constructor Detail

InternalEventRouterImpl

public InternalEventRouterImpl(EventBeanTypedEventFactory eventBeanTypedEventFactory)

Method Detail

isHasPreprocessing

public boolean isHasPreprocessing()

Return true to indicate that there is pre-processing to take place.

Specified by:

isHasPreprocessing in interface InternalEventRouter

Returns:

preprocessing indicator

preprocess

public EventBean preprocess(EventBean theEvent,
                            ExprEvaluatorContext runtimeFilterAndDispatchTimeContext,
                            InstrumentationCommon instrumentation)

Pre-process the event.

Specified by:

preprocess in interface InternalEventRouter

Parameters:

theEvent - to preprocess

runtimeFilterAndDispatchTimeContext - expression evaluation context

instrumentation - instrumentation

Returns:

preprocessed event

setInsertIntoListener

public void setInsertIntoListener(InsertIntoListener insertIntoListener)

Specified by:

setInsertIntoListener in interface InternalEventRouter

route

public void route(EventBean theEvent,
                  AgentInstanceContext agentInstanceContext,
                  boolean addToFront)

Description copied from interface: InternalEventRouter

Route the event such that the event is processed as required.

Specified by:

route in interface InternalEventRouter

Parameters:

theEvent - to route

agentInstanceContext - agentInstanceContext

addToFront - indicator whether to add to front queue

route

public void route(EventBean theEvent,
                  EPStatementHandle statementHandle,
                  InternalEventRouteDest routeDest,
                  ExprEvaluatorContext exprEvaluatorContext,
                  boolean addToFront)

addPreprocessing

public void addPreprocessing(InternalEventRouterDesc internalEventRouterDesc,
                             InternalRoutePreprocessView outputView,
                             StatementAgentInstanceLock agentInstanceLock,
                             boolean hasSubselect)

Specified by:

addPreprocessing in interface InternalEventRouter

removePreprocessing

public void removePreprocessing(EventType eventType,
                                InternalEventRouterDesc desc)

Specified by:

removePreprocessing in interface InternalEventRouter