Package org.axonframework.eventsourcing.eventstore

Class AggregateBasedConsistencyMarker

java.lang.Object

org.axonframework.eventsourcing.eventstore.AbstractConsistencyMarker<AggregateBasedConsistencyMarker>

org.axonframework.eventsourcing.eventstore.AggregateBasedConsistencyMarker

All Implemented Interfaces:

ConsistencyMarker

public class AggregateBasedConsistencyMarker
extends AbstractConsistencyMarker<AggregateBasedConsistencyMarker>

ConsistencyMarker implementation that keeps track of a position per aggregate identifier. A single AggregateBasedConsistencyMarker can track the positions of multiple Aggregates.

Since:

5.0.0

Author:

Allard Buijze

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
final class	AggregateBasedConsistencyMarker.AggregateSequencer	Helper class that tracks the sequence of events for different aggregates and manages the consistency marker for the aggregates.

Field Summary

Fields inherited from interface org.axonframework.eventsourcing.eventstore.ConsistencyMarker

INFINITY, ORIGIN, RESOURCE_KEY

Constructor Summary

Constructors

Constructor	Description
AggregateBasedConsistencyMarker(String aggregateIdentifier, long sequenceNumber)	Construct a new consistency marker for given aggregateIdentifier and sequenceNumber.

Method Summary

Modifier and Type	Method	Description
AggregateBasedConsistencyMarker.AggregateSequencer	createSequencer()	Create an AggregateBasedConsistencyMarker.AggregateSequencer, initialized with values from this marker, which can increment and provide sequence numbers of multiple aggregates, and integrate the results into a new AggregateBasedConsistencyMarker.
AggregateBasedConsistencyMarker	doLowerBound(AggregateBasedConsistencyMarker other)	Calculate the lower bound of this marker and given other marker.
AggregateBasedConsistencyMarker	doUpperBound(AggregateBasedConsistencyMarker other)	Calculate the upper bound of this marker and given other marker.
boolean	equals(Object o)
static AggregateBasedConsistencyMarker	from(AppendCondition appendCondition)	Constructs an AggregateBasedConsistencyMarker based of the given appendCondition.
int	hashCode()
Position	position()	Reduces this consistency marker to a single position if possible.
String	toString()

Methods inherited from class org.axonframework.eventsourcing.eventstore.AbstractConsistencyMarker

lowerBound, upperBound

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

Constructor Details

AggregateBasedConsistencyMarker

public AggregateBasedConsistencyMarker(String aggregateIdentifier,
 long sequenceNumber)

Construct a new consistency marker for given aggregateIdentifier and sequenceNumber.

Parameters:

aggregateIdentifier - The identifier of the aggregate to contain in the marker.

sequenceNumber - The sequence number of the last seen event of the aggregate.

Method Details

from

public static AggregateBasedConsistencyMarker from(AppendCondition appendCondition)

Constructs an AggregateBasedConsistencyMarker based of the given appendCondition. If the consistency marker of the given appendCondition is not an instance of AggregateBasedConsistencyMarker, it will attempt to create an instance that respects the condition. If such conversion is not possible, the method throws an IllegalArgumentException.

Parameters:

appendCondition - The condition to create an AggregateBasedConsistencyMarker for

Returns:

an AggregateBasedConsistencyMarker that represents the given appendCondition

Throws:

IllegalArgumentException - when the consistency marker of given append condition cannot be safely converted to an AggregateBasedConsistencyMarker.

doLowerBound

public AggregateBasedConsistencyMarker doLowerBound(AggregateBasedConsistencyMarker other)

Description copied from class: AbstractConsistencyMarker

Calculate the lower bound of this marker and given other marker. The result must represent the lowest of the given markers. This may either be on of this or the other marker, or any other that represents their lower bound.

Specified by:

doLowerBound in class AbstractConsistencyMarker<AggregateBasedConsistencyMarker>

Parameters:

other - The other marker.

Returns:

A marker representing the lower bound of this and the other marker.

doUpperBound

public AggregateBasedConsistencyMarker doUpperBound(AggregateBasedConsistencyMarker other)

Description copied from class: AbstractConsistencyMarker

Calculate the upper bound of this marker and given other marker. The result must represent the highest of the given markers. This may either be on of this or the other marker, or any other that represents their upper bound.

Specified by:

doUpperBound in class AbstractConsistencyMarker<AggregateBasedConsistencyMarker>

Parameters:

other - The other marker.

Returns:

A marker representing the upper bound of this and the other marker.

position

public Position position()

Description copied from interface: ConsistencyMarker

Reduces this consistency marker to a single position if possible. Note that this must always succeed if the marker was created based on a single sourcing. The position returned is guaranteed to be suitable to resume an earlier sourcing from the exact position it ended at.

Returns:

a Position, never null

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object

createSequencer

public AggregateBasedConsistencyMarker.AggregateSequencer createSequencer()

Create an AggregateBasedConsistencyMarker.AggregateSequencer, initialized with values from this marker, which can increment and provide sequence numbers of multiple aggregates, and integrate the results into a new AggregateBasedConsistencyMarker.

Returns:

an AggregateBasedConsistencyMarker.AggregateSequencer initialized with values from this marker, never null