com.espertech.esper.core.context.util
Class StatementAgentInstanceUtil

java.lang.Object
  extended by com.espertech.esper.core.context.util.StatementAgentInstanceUtil

public class StatementAgentInstanceUtil
extends java.lang.Object


Constructor Summary
StatementAgentInstanceUtil()
           
 
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
 

Constructor Detail

StatementAgentInstanceUtil

public StatementAgentInstanceUtil()
Method Detail

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)

© 2006-2011 EsperTech Inc.
All rights reserved.
Visit us at espertech.com