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

Class AgentInstanceUtil

java.lang.Object

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

public class AgentInstanceUtil
extends Object

Constructor Summary

Constructors

Constructor and Description
AgentInstanceUtil()

Method Summary

Modifier and Type	Method and Description
static void	contextPartitionTerminate(int agentInstanceId, ContextControllerStatementDesc statementDesc, Map<String,Object> terminationProperties, boolean leaveLocksAcquired, List<AgentInstance> agentInstancesLocksHeld)
static void	evaluateEventForStatement(EventBean theEvent, Map<String,Object> optionalTriggeringPattern, List<AgentInstance> agentInstances, AgentInstanceContext agentInstanceContextCreate)
static boolean	evaluateFilterForStatement(EventBean theEvent, AgentInstanceContext agentInstanceContext, FilterHandle filterHandle)
static AgentInstanceStopCallback	finalizeSafeStopCallbacks(List<AgentInstanceStopCallback> stopCallbacks)
static StatementAgentInstanceLock	newLock(StatementContext statementContext)
static StatementAgentInstanceFactoryResult	start(StatementContextRuntimeServices services, ContextControllerStatementDesc statement, int agentInstanceId, MappedEventBean contextProperties, AgentInstanceFilterProxy agentInstanceFilterProxy, boolean isRecoveringResilient)
static AgentInstance	startStatement(StatementContextRuntimeServices services, int assignedContextId, ContextControllerStatementDesc statementDesc, MappedEventBean contextBean, AgentInstanceFilterProxy proxy)
static void	stop(AgentInstanceStopCallback stopCallback, AgentInstanceContext agentInstanceContext, Viewable finalView, boolean isStatementStop, boolean leaveLocksAcquired)
static void	stopSafe(AgentInstanceStopCallback stopMethod, AgentInstanceContext agentInstanceContext)

Methods inherited from class java.lang.Object

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

Constructor Detail

AgentInstanceUtil

public AgentInstanceUtil()

Method Detail

evaluateEventForStatement

public static void evaluateEventForStatement(EventBean theEvent,
                                             Map<String,Object> optionalTriggeringPattern,
                                             List<AgentInstance> agentInstances,
                                             AgentInstanceContext agentInstanceContextCreate)

contextPartitionTerminate

public static void contextPartitionTerminate(int agentInstanceId,
                                             ContextControllerStatementDesc statementDesc,
                                             Map<String,Object> terminationProperties,
                                             boolean leaveLocksAcquired,
                                             List<AgentInstance> agentInstancesLocksHeld)

stop

public static void stop(AgentInstanceStopCallback stopCallback,
                        AgentInstanceContext agentInstanceContext,
                        Viewable finalView,
                        boolean isStatementStop,
                        boolean leaveLocksAcquired)

stopSafe

public static void stopSafe(AgentInstanceStopCallback stopMethod,
                            AgentInstanceContext agentInstanceContext)

finalizeSafeStopCallbacks

public static AgentInstanceStopCallback finalizeSafeStopCallbacks(List<AgentInstanceStopCallback> stopCallbacks)

startStatement

public static AgentInstance startStatement(StatementContextRuntimeServices services,
                                           int assignedContextId,
                                           ContextControllerStatementDesc statementDesc,
                                           MappedEventBean contextBean,
                                           AgentInstanceFilterProxy proxy)

start

public static StatementAgentInstanceFactoryResult start(StatementContextRuntimeServices services,
                                                        ContextControllerStatementDesc statement,
                                                        int agentInstanceId,
                                                        MappedEventBean contextProperties,
                                                        AgentInstanceFilterProxy agentInstanceFilterProxy,
                                                        boolean isRecoveringResilient)

evaluateFilterForStatement

public static boolean evaluateFilterForStatement(EventBean theEvent,
                                                 AgentInstanceContext agentInstanceContext,
                                                 FilterHandle filterHandle)

newLock

public static StatementAgentInstanceLock newLock(StatementContext statementContext)