Package com.espertech.esper.common.internal.context.mgr

Class ContextManagerRealization

java.lang.Object

com.espertech.esper.common.internal.context.mgr.ContextManagerRealization

All Implemented Interfaces:

ContextControllerLifecycleCallback, FilterFaultHandler

public class ContextManagerRealization
extends Object
implements ContextControllerLifecycleCallback, FilterFaultHandler

Constructor Summary

Constructors

Constructor	Description
ContextManagerRealization(ContextManagerResident contextManager, AgentInstanceContext agentInstanceContextCreate)

Method Summary

Modifier and Type	Method	Description
void	activateCreateVariableStatement(ContextControllerStatementDesc statement)
ContextPartitionInstantiationResult	contextPartitionInstantiate(IntSeqKey controllerPathId, int subpathId, ContextController originator, EventBean optionalTriggeringEvent, Map<String,Object> optionalPatternForInclusiveEval, Object[] parentPartitionKeys, Object partitionKey)
void	contextPartitionRecursiveVisit(IntSeqKey controllerPath, int subpathOrAgentInstanceId, ContextController originator, ContextPartitionVisitor visitor, ContextPartitionSelector[] selectorPerLevel)
void	contextPartitionTerminate(IntSeqKey controllerPath, int subpathIdOrCPId, ContextController originator, Map<String,Object> terminationProperties, boolean leaveLocksAcquired, List<AgentInstance> agentInstancesLocksHeld)
AgentInstanceContext	getAgentInstanceContextCreate()
Collection<Integer>	getAgentInstanceIds(ContextPartitionSelector selector)
ContextController[]	getContextControllers()
ContextManagerResident	getContextManager()
boolean	handleFilterFault(EventBean theEvent, long version)
void	removeStatement(ContextControllerStatementDesc statementDesc)
void	safeDestroyContext()
void	startContext()
void	startLateStatement(ContextControllerStatementDesc statement)
void	stopContext()
void	transfer(AgentInstanceTransferServices xfer)
void	transferRecursive(IntSeqKey controllerPath, int subpathOrAgentInstanceId, ContextController originator, AgentInstanceTransferServices xfer)

Methods inherited from class java.lang.Object

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

Constructor Details

ContextManagerRealization

public ContextManagerRealization(ContextManagerResident contextManager,
 AgentInstanceContext agentInstanceContextCreate)

Method Details

getContextControllers

public ContextController[] getContextControllers()

startContext

public void startContext()

stopContext

public void stopContext()

safeDestroyContext

public void safeDestroyContext()

contextPartitionInstantiate

public ContextPartitionInstantiationResult contextPartitionInstantiate(IntSeqKey controllerPathId,
 int subpathId,
 ContextController originator,
 EventBean optionalTriggeringEvent,
 Map<String,Object> optionalPatternForInclusiveEval,
 Object[] parentPartitionKeys,
 Object partitionKey)

Specified by:

contextPartitionInstantiate in interface ContextControllerLifecycleCallback

contextPartitionTerminate

public void contextPartitionTerminate(IntSeqKey controllerPath,
 int subpathIdOrCPId,
 ContextController originator,
 Map<String,Object> terminationProperties,
 boolean leaveLocksAcquired,
 List<AgentInstance> agentInstancesLocksHeld)

Specified by:

contextPartitionTerminate in interface ContextControllerLifecycleCallback

startLateStatement

public void startLateStatement(ContextControllerStatementDesc statement)

getAgentInstanceContextCreate

public AgentInstanceContext getAgentInstanceContextCreate()

getAgentInstanceIds

public Collection<Integer> getAgentInstanceIds(ContextPartitionSelector selector)

removeStatement

public void removeStatement(ContextControllerStatementDesc statementDesc)

contextPartitionRecursiveVisit

public void contextPartitionRecursiveVisit(IntSeqKey controllerPath,
 int subpathOrAgentInstanceId,
 ContextController originator,
 ContextPartitionVisitor visitor,
 ContextPartitionSelector[] selectorPerLevel)

Specified by:

contextPartitionRecursiveVisit in interface ContextControllerLifecycleCallback

getContextManager

public ContextManagerResident getContextManager()

activateCreateVariableStatement

public void activateCreateVariableStatement(ContextControllerStatementDesc statement)

handleFilterFault

public boolean handleFilterFault(EventBean theEvent,
 long version)

Specified by:

handleFilterFault in interface FilterFaultHandler

transfer

public void transfer(AgentInstanceTransferServices xfer)

transferRecursive

public void transferRecursive(IntSeqKey controllerPath,
 int subpathOrAgentInstanceId,
 ContextController originator,
 AgentInstanceTransferServices xfer)