com.espertech.esper.core.context.mgr

Interface ContextControllerLifecycleCallback

All Known Implementing Classes:

ContextManagerImpl, ContextManagerNested

public interface ContextControllerLifecycleCallback

Method Summary

Modifier and Type	Method and Description
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, java.util.function.Supplier<ContextPartitionIdentifier> identifier)
void	contextPartitionNavigate(ContextControllerInstanceHandle existingHandle, ContextController originator, ContextControllerState controllerState, int exportedCPOrPathId, ContextInternalFilterAddendum filterAddendum, AgentInstanceSelector agentInstanceSelector, byte[] payload, boolean isRecoveringResilient)
void	contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle, java.util.Map<java.lang.String,java.lang.Object> terminationProperties, boolean leaveLocksAcquired, java.util.List<AgentInstance> agentInstances)

Method Detail

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,
                                                            java.util.function.Supplier<ContextPartitionIdentifier> identifier)

contextPartitionNavigate

void contextPartitionNavigate(ContextControllerInstanceHandle existingHandle,
                              ContextController originator,
                              ContextControllerState controllerState,
                              int exportedCPOrPathId,
                              ContextInternalFilterAddendum filterAddendum,
                              AgentInstanceSelector agentInstanceSelector,
                              byte[] payload,
                              boolean isRecoveringResilient)

contextPartitionTerminate

void contextPartitionTerminate(ContextControllerInstanceHandle contextNestedHandle,
                               java.util.Map<java.lang.String,java.lang.Object> terminationProperties,
                               boolean leaveLocksAcquired,
                               java.util.List<AgentInstance> agentInstances)