Package 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

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	AgentInstanceUtil.AgentInstanceFinalizedMgmtCallback

Constructor Summary

Constructors

Constructor	Description
AgentInstanceUtil()

Method Summary

Modifier and Type	Method	Description
static void	contextPartitionTerminate(int agentInstanceId, ContextControllerStatementDesc statementDesc, ContextController[] contextControllers, 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 AgentInstanceMgmtCallback	finalizeSafeStopCallbacks(List<AgentInstanceMgmtCallback> stopCallbacks)
static StatementAgentInstanceLock	newLock(StatementContext statementContext, int cpid)
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(AgentInstanceMgmtCallback stopCallback, AgentInstanceContext agentInstanceContext, Viewable finalView, boolean isStatementStop, boolean leaveLocksAcquired)
static void	stopSafe(AgentInstanceMgmtCallback stopMethod, AgentInstanceContext agentInstanceContext)

Methods inherited from class java.lang.Object

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

Constructor Details

AgentInstanceUtil

public AgentInstanceUtil()

Method Details

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,
 ContextController[] contextControllers,
 Map<String,Object> terminationProperties,
 boolean leaveLocksAcquired,
 List<AgentInstance> agentInstancesLocksHeld)

stop

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

stopSafe

public static void stopSafe(AgentInstanceMgmtCallback stopMethod,
 AgentInstanceContext agentInstanceContext)

finalizeSafeStopCallbacks

public static AgentInstanceMgmtCallback finalizeSafeStopCallbacks(List<AgentInstanceMgmtCallback> 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,
 int cpid)