Package 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	Description
InternalEventRouterImpl(EventBeanTypedEventFactory eventBeanTypedEventFactory)

Method Summary

Modifier and Type	Method	Description
void	addPreprocessing(InternalEventRouterDesc internalEventRouterDesc, InternalRoutePreprocessView outputView, StatementContext statementContext, boolean hasSubselect)
boolean	isHasPreprocessing()	Return true to indicate that there is pre-processing to take place.
void	movePreprocessing(StatementContext statementContext, InternalEventRouter internalEventRouter)
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, int precedence)	Route the event such that the event is processed as required.
void	route(EventBean theEvent, EPStatementHandle statementHandle, InternalEventRouteDest routeDest, ExprEvaluatorContext exprEvaluatorContext, boolean addToFront, int precedence)
void	setInsertIntoListener(InsertIntoListener insertIntoListener)

Methods inherited from class java.lang.Object

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

Constructor Details

InternalEventRouterImpl

public InternalEventRouterImpl(EventBeanTypedEventFactory eventBeanTypedEventFactory)

Method Details

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,
 int precedence)

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

precedence - event precedence

route

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

addPreprocessing

public void addPreprocessing(InternalEventRouterDesc internalEventRouterDesc,
 InternalRoutePreprocessView outputView,
 StatementContext statementContext,
 boolean hasSubselect)

Specified by:

addPreprocessing in interface InternalEventRouter

removePreprocessing

public void removePreprocessing(EventType eventType,
 InternalEventRouterDesc desc)

Specified by:

removePreprocessing in interface InternalEventRouter

movePreprocessing

public void movePreprocessing(StatementContext statementContext,
 InternalEventRouter internalEventRouter)