Uses of Interface
org.axonframework.messaging.core.sequencing.SequencingPolicy
Packages that use SequencingPolicy
Package
Description
Contains the multi-tenancy API, like the tenant descriptor, tenant provider, and tenant resolution contracts.
Internal implementation of the workflow execution engine: the
WorkflowEngine, its scheduling, state and
storage, checkpointing/replay support, cancellation coordination, and the delegates implementing individual step
primitives.Part of the Axon Messaging module.
Part of the Axon Messaging module.
Package for event handling components in Axon Framework.
Part of the Axon Messaging module.
Part of the Axon Messaging module.
-
Uses of SequencingPolicy in io.axoniq.framework.messaging.multitenancy.api
Subinterfaces of SequencingPolicy in io.axoniq.framework.messaging.multitenancy.apiModifier and TypeInterfaceDescriptioninterfaceASequencingPolicythat sequences messages by the tenant resolved for message processing. -
Uses of SequencingPolicy in io.axoniq.framework.workflow.runtime.execution
Methods in io.axoniq.framework.workflow.runtime.execution that return SequencingPolicyModifier and TypeMethodDescriptionWorkflowEngine.segmentedRouting()Returns the sequencing policy derived from this engine's workflow definitions, which delivers each event to the segment owning the workflow instance it affects. -
Uses of SequencingPolicy in org.axonframework.messaging.commandhandling.interception
Constructors in org.axonframework.messaging.commandhandling.interception with parameters of type SequencingPolicyModifierConstructorDescriptionCommandSequencingInterceptor(SequencingPolicy<? super CommandMessage> sequencingPolicy) Construct aCommandSequencingInterceptorthat sequences command execution based on the suppliedSequencingPolicy. -
Uses of SequencingPolicy in org.axonframework.messaging.core.sequencing
Classes in org.axonframework.messaging.core.sequencing that implement SequencingPolicyModifier and TypeClassDescriptionclassASequencingPolicyimplementation that extracts the sequence identifier from the message payload based on a given property extractor.classFallbackSequencingPolicy<E extends Exception,M extends Message> Implementation ofSequencingPolicythat provides exception-based fallback behavior.classSequencingPolicy that does not enforce any sequencing requirements on message processing.classHierarchicalSequencingPolicy<M extends Message>Implementation ofSequencingPolicythat combines two policies in a fallback pattern.classASequencingPolicyimplementation that extracts the sequence identifier from theMessage'sMetadata, based on a givenmetadataKey.classSequencingPolicythat imposes no sequencing at all on the processing of messages.classASequencingPolicyimplementation that extracts the sequence identifier from the message payload based on a given property.classRoutingKeySequencingPolicythat requires sequential processing of commands targeting the samerouting key.classConcurrency policy that requires sequential processing of events raised by the same aggregate.classSequencingPolicy that requires sequential handling of all messages delivered to a message handler.Constructors in org.axonframework.messaging.core.sequencing with parameters of type SequencingPolicyModifierConstructorDescriptionFallbackSequencingPolicy(SequencingPolicy<? super M> delegate, SequencingPolicy<? super M> fallback, Class<E> exceptionType) Initializes a new instance with the givendelegatepolicy,fallbackpolicy, andexceptionTypeto catch.HierarchicalSequencingPolicy(SequencingPolicy<? super M> primary, SequencingPolicy<? super M> secondary) Initializes a new instance with the given primarydelegateandfallbackpolicies. -
Uses of SequencingPolicy in org.axonframework.messaging.eventhandling
Methods in org.axonframework.messaging.eventhandling with parameters of type SequencingPolicyModifier and TypeMethodDescriptionstatic SimpleEventHandlingComponentSimpleEventHandlingComponent.create(String name, SequencingPolicy<? super EventMessage> sequencingPolicy) Instantiates a simpleEventHandlingComponentthat is able to handle events and delegate them to subcomponents, using the givensequencingPolicyto decide how to sequence incoming events.SimpleEventHandlingComponent.overridePolicyWhenDefault(SequencingPolicy<? super EventMessage> sequencingPolicy) Replaces the defaultSequencingPolicyof aSimpleEventHandlingComponentwith the givensequencingPolicy, only if the default is in place.Constructors in org.axonframework.messaging.eventhandling with parameters of type SequencingPolicyModifierConstructorDescriptionprotectedSimpleEventHandlingComponent(String name, SequencingPolicy<? super EventMessage> sequencingPolicy) -
Uses of SequencingPolicy in org.axonframework.messaging.eventhandling.processing.streaming.pooled
Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled that return SequencingPolicyModifier and TypeMethodDescription@Nullable SequencingPolicy<? super EventMessage> PooledStreamingEventProcessorConfiguration.sequencingPolicy()Returns theSequencingPolicythis processor applies to assignedEventHandlingComponentsthat do not define a more specific one.Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled with parameters of type SequencingPolicyModifier and TypeMethodDescriptionPooledStreamingEventProcessorConfiguration.sequencingPolicy(SequencingPolicy<? super EventMessage> sequencingPolicy) Sets theSequencingPolicyused to determine the sequence identifier of events handled by thisPooledStreamingEventProcessor, whenever an assignedEventHandlingComponentdoes not define a more specific one. -
Uses of SequencingPolicy in org.axonframework.messaging.eventhandling.processing.streaming.segmenting
Constructors in org.axonframework.messaging.eventhandling.processing.streaming.segmenting with parameters of type SequencingPolicyModifierConstructorDescriptionSequenceOverridingEventHandlingComponent(SequencingPolicy<? super EventMessage> sequencingPolicy, EventHandlingComponent delegate) Creates a newSequenceOverridingEventHandlingComponentthat uses the givensequencingPolicyto override sequence identification while delegating all other operations to thedelegatecomponent.