Package org.axonframework.axonserver.connector.event.axon

Class PersistentStreamSequencingPolicyProvider

java.lang.Object

org.axonframework.axonserver.connector.event.axon.PersistentStreamSequencingPolicyProvider

All Implemented Interfaces:

Function<Configuration,SequencingPolicy<? super EventMessage<?>>>

public class PersistentStreamSequencingPolicyProvider
extends Object
implements Function<Configuration,SequencingPolicy<? super EventMessage<?>>>

A provider of SequencingPolicies for a given Configuration.

The provided SequencingPolicy for a given Configuration returns a sequencing key for an event to identify which sequence/stream the event belongs to. The policy is only used for when a dead letter queue is attached to the processors consuming from a Persistent Stream.

Since:

4.10.0

Author:

Marc Gathier

Field Summary

Fields

Modifier and Type	Field	Description
static final String	FULL_CONCURRENCY_POLICY	A String constant representing the full concurrency policy.
static final String	META_DATA_SEQUENCING_POLICY	A String constant representing the "meta-data" sequencing policy.
static final String	PROPERTY_SEQUENCING_POLICY	A String constant representing the property sequencing policy.
static final String	SEQUENTIAL_PER_AGGREGATE_POLICY	A String constant representing the "sequential per aggregate" sequencing policy.
static final String	SEQUENTIAL_POLICY	A String constant representing the sequential policy.

Constructor Summary

Constructors

Constructor	Description
PersistentStreamSequencingPolicyProvider(String name, String sequencingPolicy, List<String> sequencingPolicyParameters)	Instantiates a PersistentStreamSequencingPolicyProvider based on the given parameters.

Method Summary

Modifier and Type	Method	Description
SequencingPolicy<EventMessage<?>>	apply(Configuration configuration)

Methods inherited from class java.lang.Object

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

Methods inherited from interface java.util.function.Function

andThen, compose

Field Details

SEQUENTIAL_PER_AGGREGATE_POLICY

public static final String SEQUENTIAL_PER_AGGREGATE_POLICY

A String constant representing the "sequential per aggregate" sequencing policy. This means all events belonging to the same aggregate are handled sequentially. The behavior of this policy resembles the SequentialPerAggregatePolicy.

See Also:

• Constant Field Values

META_DATA_SEQUENCING_POLICY

public static final String META_DATA_SEQUENCING_POLICY

A String constant representing the "meta-data" sequencing policy. The policy utilizes values present in the metadata of an event to define the sequence identifier.

See Also:

• Constant Field Values

SEQUENTIAL_POLICY

public static final String SEQUENTIAL_POLICY

A String constant representing the sequential policy. This means all events are handled sequentially. The behavior of this policy resembles the SequentialPolicy.

See Also:

• Constant Field Values

FULL_CONCURRENCY_POLICY

public static final String FULL_CONCURRENCY_POLICY

A String constant representing the full concurrency policy. This means all events are spread out over the available segments, regardless of the sequence identifier. The behavior of this policy resembles the FullConcurrencyPolicy.

See Also:

• Constant Field Values

PROPERTY_SEQUENCING_POLICY

public static final String PROPERTY_SEQUENCING_POLICY

A String constant representing the property sequencing policy. This policy retrieves a value from the event's payload to decide the sequence identifier of the event. The behavior of this policy resembles the PropertySequencingPolicy.

See Also:

• Constant Field Values

Constructor Details

PersistentStreamSequencingPolicyProvider

public PersistentStreamSequencingPolicyProvider(String name,
 String sequencingPolicy,
 List<String> sequencingPolicyParameters)

Instantiates a PersistentStreamSequencingPolicyProvider based on the given parameters.

Parameters:

name - The processor name.

sequencingPolicy - The name of the sequencing policy.

sequencingPolicyParameters - Parameters for the sequencing policy.

Method Details

apply

public SequencingPolicy<EventMessage<?>> apply(Configuration configuration)

Specified by:

apply in interface Function<Configuration,SequencingPolicy<? super EventMessage<?>>>