com.espertech.esper.core.context.mgr
Interface ContextControllerLifecycleCallback
- All Known Implementing Classes:
- ContextManagerImpl, ContextManagerNested
public interface ContextControllerLifecycleCallback
Method Summary |
ContextControllerInstanceHandle |
contextPartitionInstantiate(java.lang.Integer optionalContextPartitionId,
int subpath,
java.lang.Integer importSubpathId,
ContextController originator,
EventBean optionalTriggeringEvent,
java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
java.lang.Object partitionKey,
java.util.Map<java.lang.String,java.lang.Object> contextProperties,
ContextControllerState states,
ContextInternalFilterAddendum filterAddendum,
boolean isRecoveringResilient,
ContextPartitionState state)
|
void |
contextPartitionNavigate(ContextControllerInstanceHandle existingHandle,
ContextController originator,
ContextControllerState controllerState,
int exportedCPOrPathId,
ContextInternalFilterAddendum filterAddendum,
AgentInstanceSelector agentInstanceSelector,
byte[] payload)
|
void |
contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
boolean leaveLocksAcquired,
java.util.List<AgentInstance> agentInstances)
|
contextPartitionInstantiate
ContextControllerInstanceHandle contextPartitionInstantiate(java.lang.Integer optionalContextPartitionId,
int subpath,
java.lang.Integer importSubpathId,
ContextController originator,
EventBean optionalTriggeringEvent,
java.util.Map<java.lang.String,java.lang.Object> optionalTriggeringPattern,
java.lang.Object partitionKey,
java.util.Map<java.lang.String,java.lang.Object> contextProperties,
ContextControllerState states,
ContextInternalFilterAddendum filterAddendum,
boolean isRecoveringResilient,
ContextPartitionState state)
contextPartitionNavigate
void contextPartitionNavigate(ContextControllerInstanceHandle existingHandle,
ContextController originator,
ContextControllerState controllerState,
int exportedCPOrPathId,
ContextInternalFilterAddendum filterAddendum,
AgentInstanceSelector agentInstanceSelector,
byte[] payload)
contextPartitionTerminate
void contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle,
java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
boolean leaveLocksAcquired,
java.util.List<AgentInstance> agentInstances)