com.espertech.esper.core.context.util
Class StatementAgentInstanceUtil
java.lang.Object
com.espertech.esper.core.context.util.StatementAgentInstanceUtil
public class StatementAgentInstanceUtil
- extends java.lang.Object
Method Summary |
static void |
evaluateEventForStatement(EPServicesContext servicesContext,
EventBean theEvent,
java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
AgentInstanceContext agentInstanceContext)
|
static boolean |
evaluateFilterForStatement(EPServicesContext servicesContext,
EventBean theEvent,
AgentInstanceContext agentInstanceContext,
FilterHandle filterHandle)
|
static StopCallback |
getStopCallback(java.util.List<StopCallback> stopCallbacks,
AgentInstanceContext agentInstanceContext)
|
static void |
handleFilterFault(EventBean theEvent,
long version,
EPServicesContext servicesContext,
java.util.Map<java.lang.Integer,ContextControllerTreeAgentInstanceList> agentInstanceListMap)
|
static StatementAgentInstanceFactoryResult |
start(EPServicesContext servicesContext,
ContextControllerStatementBase statement,
boolean isSingleInstanceContext,
int agentInstanceId,
MappedEventBean agentInstanceProperties,
AgentInstanceFilterProxy agentInstanceFilterProxy,
boolean isRecoveringResilient)
|
static void |
stop(StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable finalView,
EPServicesContext servicesContext,
boolean isStatementStop)
|
static void |
stopAgentInstance(AgentInstance agentInstance,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
EPServicesContext servicesContext,
boolean isStatementStop)
|
static void |
stopAgentInstances(java.util.List<AgentInstance> agentInstances,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
EPServicesContext servicesContext,
boolean isStatementStop)
|
static void |
stopSafe(java.util.Collection<StopCallback> terminationCallbacks,
StopCallback[] stopCallbacks,
StatementContext statementContext)
|
static void |
stopSafe(StopCallback[] stopMethods,
StatementContext statementContext)
|
static void |
stopSafe(StopCallback stopMethod,
StatementContext statementContext)
|
Methods inherited from class java.lang.Object |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait |
StatementAgentInstanceUtil
public StatementAgentInstanceUtil()
handleFilterFault
public static void handleFilterFault(EventBean theEvent,
long version,
EPServicesContext servicesContext,
java.util.Map<java.lang.Integer,ContextControllerTreeAgentInstanceList> agentInstanceListMap)
stopAgentInstances
public static void stopAgentInstances(java.util.List<AgentInstance> agentInstances,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
EPServicesContext servicesContext,
boolean isStatementStop)
stopAgentInstance
public static void stopAgentInstance(AgentInstance agentInstance,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
EPServicesContext servicesContext,
boolean isStatementStop)
stopSafe
public static void stopSafe(java.util.Collection<StopCallback> terminationCallbacks,
StopCallback[] stopCallbacks,
StatementContext statementContext)
stopSafe
public static void stopSafe(StopCallback[] stopMethods,
StatementContext statementContext)
stopSafe
public static void stopSafe(StopCallback stopMethod,
StatementContext statementContext)
stop
public static void stop(StopCallback stopCallback,
AgentInstanceContext agentInstanceContext,
Viewable finalView,
EPServicesContext servicesContext,
boolean isStatementStop)
start
public static StatementAgentInstanceFactoryResult start(EPServicesContext servicesContext,
ContextControllerStatementBase statement,
boolean isSingleInstanceContext,
int agentInstanceId,
MappedEventBean agentInstanceProperties,
AgentInstanceFilterProxy agentInstanceFilterProxy,
boolean isRecoveringResilient)
evaluateEventForStatement
public static void evaluateEventForStatement(EPServicesContext servicesContext,
EventBean theEvent,
java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
AgentInstanceContext agentInstanceContext)
evaluateFilterForStatement
public static boolean evaluateFilterForStatement(EPServicesContext servicesContext,
EventBean theEvent,
AgentInstanceContext agentInstanceContext,
FilterHandle filterHandle)
getStopCallback
public static StopCallback getStopCallback(java.util.List<StopCallback> stopCallbacks,
AgentInstanceContext agentInstanceContext)