Uses of Interface
org.axonframework.eventsourcing.eventstore.TrackingToken

Packages that use TrackingToken

Package	Description
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
org.axonframework.eventhandling.saga
org.axonframework.eventhandling.saga.repository
org.axonframework.eventhandling.saga.repository.inmemory
org.axonframework.eventhandling.saga.repository.jdbc
org.axonframework.eventhandling.saga.repository.jpa
org.axonframework.eventhandling.tokenstore
org.axonframework.eventhandling.tokenstore.inmemory
org.axonframework.eventhandling.tokenstore.jdbc
org.axonframework.eventhandling.tokenstore.jpa
org.axonframework.eventsourcing	Classes related to event sourcing.
org.axonframework.eventsourcing.eventstore	Definitions and implementations of the Event store, the mechanism that can load event streams and append events to them.
org.axonframework.eventsourcing.eventstore.inmemory
org.axonframework.eventsourcing.eventstore.jdbc	JDBC Implementation of the EventStore.
org.axonframework.eventsourcing.eventstore.jpa	JPA Implementation of the EventStore.
org.axonframework.kafka.eventhandling.consumer
org.axonframework.messaging	Classes related to message processing in Axon Framework.
org.axonframework.mongo.eventhandling.saga.repository
org.axonframework.mongo.eventsourcing.eventstore
org.axonframework.mongo.eventsourcing.tokenstore
org.axonframework.serialization.upcasting.event

Uses of TrackingToken in org.axonframework.eventhandling

Classes in org.axonframework.eventhandling that implement TrackingToken

Modifier and Type	Class and Description
class	ReplayToken Token keeping track of the position before a reset was triggered.

Methods in org.axonframework.eventhandling that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	ReplayToken.advancedTo(TrackingToken newToken) Advance this token to the given newToken.
static TrackingToken	ReplayToken.createReplayToken(TrackingToken tokenAtReset) Creates a new TrackingToken that represents the tail position of a stream, in reset state, when appropriate.
static TrackingToken	ReplayToken.createReplayToken(TrackingToken tokenAtReset, TrackingToken startPosition) Creates a new TrackingToken that represents the given startPosition of a stream, in reset state, when appropriate.
TrackingToken	ReplayToken.getCurrentToken() Gets the current token.
TrackingToken	ReplayToken.getTokenAtReset() Gets the token representing the position at which the reset was triggered.
TrackingToken	EventTrackerStatus.getTrackingToken() The tracking token of the last event that has been seen by this Segment
TrackingToken	ReplayToken.lowerBound(TrackingToken other)
TrackingToken	TrackedEventMessage.trackingToken() Returns the TrackingToken of the event message.
TrackingToken	GenericTrackedEventMessage.trackingToken()
TrackingToken	WrappedToken.unwrap() Returns the token representing the current position in the stream.
TrackingToken	ReplayToken.unwrap()
TrackingToken	ReplayToken.upperBound(TrackingToken other)

Methods in org.axonframework.eventhandling that return types with arguments of type TrackingToken

Modifier and Type	Method and Description
Function<StreamableMessageSource,TrackingToken>	TrackingEventProcessorConfiguration.getInitialTrackingToken()

Methods in org.axonframework.eventhandling with parameters of type TrackingToken

Modifier and Type	Method and Description
TrackingToken	ReplayToken.advancedTo(TrackingToken newToken) Advance this token to the given newToken.
boolean	ReplayToken.covers(TrackingToken other)
static TrackingToken	ReplayToken.createReplayToken(TrackingToken tokenAtReset) Creates a new TrackingToken that represents the tail position of a stream, in reset state, when appropriate.
static TrackingToken	ReplayToken.createReplayToken(TrackingToken tokenAtReset, TrackingToken startPosition) Creates a new TrackingToken that represents the given startPosition of a stream, in reset state, when appropriate.
static boolean	ReplayToken.isReplay(TrackingToken trackingToken) Indicates whether the given trackingToken represents a position that is part of a replay.
TrackingToken	ReplayToken.lowerBound(TrackingToken other)
TrackingEventStream	SimpleEventBus.openStream(TrackingToken trackingToken) This implementation only returns a stream if the specified trackingToken is null.
TrackingEventStream	EventBus.openStream(TrackingToken trackingToken) Open an event stream containing all events since given tracking token.
void	TrackingEventProcessor.resetTokens(TrackingToken startPosition) Resets tokens to the given startPosition.
TrackingToken	ReplayToken.upperBound(TrackingToken other)

Method parameters in org.axonframework.eventhandling with type arguments of type TrackingToken

Modifier and Type	Method and Description
TrackingEventProcessorConfiguration	TrackingEventProcessorConfiguration.andInitialTrackingToken(Function<StreamableMessageSource,TrackingToken> initialTrackingTokenBuilder) Sets the Builder to use to create the initial tracking token.
void	TrackingEventProcessor.resetTokens(Function<StreamableMessageSource,TrackingToken> initialTrackingTokenSupplier) Reset tokens to the position as return by the given initialTrackingTokenSupplier.

Constructors in org.axonframework.eventhandling with parameters of type TrackingToken

Constructor and Description
GenericTrackedEventMessage(TrackingToken trackingToken, EventMessage<T> delegate) Creates a GenericTrackedEventMessage with given trackingToken and delegate event message.
GenericTrackedEventMessage(TrackingToken trackingToken, Message<T> delegate, Instant timestamp) Initializes a GenericTrackedEventMessage with given message as delegate and given timestamp.
GenericTrackedEventMessage(TrackingToken trackingToken, Message<T> delegate, Supplier<Instant> timestamp) Creates a GenericTrackedEventMessage with given trackingToken and delegate event message.
ReplayToken(TrackingToken tokenAtReset) Initialize a ReplayToken, using the given tokenAtReset to represent the position at which a reset was triggered.
ReplayToken(TrackingToken tokenAtReset, TrackingToken newRedeliveryToken) Initializes a ReplayToken with tokenAtReset which represents the position at which a reset was triggered and the newRedeliveryToken which represents current token.

Uses of TrackingToken in org.axonframework.eventhandling.saga

Methods in org.axonframework.eventhandling.saga that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	Saga.trackingToken() Returns the TrackingToken belonging to the EventMessage last processed by this instance, or null if this instance never handled an EventMessage, or if it received an EventMessage that doesn't carry a TrackingToken.
TrackingToken	AnnotatedSaga.trackingToken()

Constructors in org.axonframework.eventhandling.saga with parameters of type TrackingToken

Constructor and Description
AnnotatedSaga(String sagaId, Set<AssociationValue> associationValues, T annotatedSaga, TrackingToken trackingToken, SagaModel<T> metaModel) Creates an AnnotatedSaga instance to wrap the given annotatedSaga, identifier with the given sagaId and associated with the given associationValues.

Uses of TrackingToken in org.axonframework.eventhandling.saga.repository

Methods in org.axonframework.eventhandling.saga.repository that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	SagaStore.Entry.trackingToken() Returns the tracking token of the last event handled by the Saga.

Methods in org.axonframework.eventhandling.saga.repository with parameters of type TrackingToken

Modifier and Type	Method and Description
void	SagaStore.insertSaga(Class<? extends T> sagaType, String sagaIdentifier, T saga, TrackingToken token, Set<AssociationValue> associationValues) Adds a new Saga and its initial association values to the store.
void	CachingSagaStore.insertSaga(Class<? extends T> sagaType, String sagaIdentifier, T saga, TrackingToken token, Set<AssociationValue> associationValues)
void	SagaStore.updateSaga(Class<? extends T> sagaType, String sagaIdentifier, T saga, TrackingToken token, AssociationValues associationValues) Updates a given Saga after its state was modified.
void	CachingSagaStore.updateSaga(Class<? extends T> sagaType, String sagaIdentifier, T saga, TrackingToken token, AssociationValues associationValues)

Uses of TrackingToken in org.axonframework.eventhandling.saga.repository.inmemory

Methods in org.axonframework.eventhandling.saga.repository.inmemory with parameters of type TrackingToken

Modifier and Type	Method and Description
void	InMemorySagaStore.insertSaga(Class<?> sagaType, String sagaIdentifier, Object saga, TrackingToken token, Set<AssociationValue> associationValues)
void	InMemorySagaStore.updateSaga(Class<?> sagaType, String sagaIdentifier, Object saga, TrackingToken token, AssociationValues associationValues)

Uses of TrackingToken in org.axonframework.eventhandling.saga.repository.jdbc

Methods in org.axonframework.eventhandling.saga.repository.jdbc with parameters of type TrackingToken

Modifier and Type	Method and Description
void	JdbcSagaStore.insertSaga(Class<?> sagaType, String sagaIdentifier, Object saga, TrackingToken token, Set<AssociationValue> associationValues)
void	JdbcSagaStore.updateSaga(Class<?> sagaType, String sagaIdentifier, Object saga, TrackingToken token, AssociationValues associationValues)

Uses of TrackingToken in org.axonframework.eventhandling.saga.repository.jpa

Methods in org.axonframework.eventhandling.saga.repository.jpa with parameters of type TrackingToken

Modifier and Type	Method and Description
void	JpaSagaStore.insertSaga(Class<?> sagaType, String sagaIdentifier, Object saga, TrackingToken token, Set<AssociationValue> associationValues)
void	JpaSagaStore.updateSaga(Class<?> sagaType, String sagaIdentifier, Object saga, TrackingToken token, AssociationValues associationValues)

Uses of TrackingToken in org.axonframework.eventhandling.tokenstore

Methods in org.axonframework.eventhandling.tokenstore that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	TokenStore.fetchToken(String processorName, int segment) Returns the last stored token for the given processorName and segment.
TrackingToken	AbstractTokenEntry.getToken(Serializer serializer) Returns the token, deserializing it with given serializer

Methods in org.axonframework.eventhandling.tokenstore with parameters of type TrackingToken

Modifier and Type	Method and Description
default void	TokenStore.initializeTokenSegments(String processorName, int segmentCount, TrackingToken initialToken) Initializes the given segmentCount number of segments for the given processorName to track its tokens.
void	TokenStore.storeToken(TrackingToken token, String processorName, int segment) Stores the given token in the store.
void	GenericTokenEntry.updateToken(TrackingToken token, Serializer serializer)
abstract void	AbstractTokenEntry.updateToken(TrackingToken token, Serializer serializer) Update this entry with the given token, serializing it using given serializer.
protected void	AbstractTokenEntry.updateToken(TrackingToken token, Serializer serializer, Class<T> contentType) Update the token data to the given token, using given serializer to serialize it to the given contentType.

Constructors in org.axonframework.eventhandling.tokenstore with parameters of type TrackingToken

Constructor and Description
AbstractTokenEntry(TrackingToken token, Serializer serializer, Class<T> contentType) Initializes a new token entry for given token, process and segment.
GenericTokenEntry(TrackingToken token, Serializer serializer, Class<T> contentType, String processorName, int segment) Initializes a new token entry for given token, process and segment.

Uses of TrackingToken in org.axonframework.eventhandling.tokenstore.inmemory

Methods in org.axonframework.eventhandling.tokenstore.inmemory that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	InMemoryTokenStore.fetchToken(String processorName, int segment)

Methods in org.axonframework.eventhandling.tokenstore.inmemory with parameters of type TrackingToken

Modifier and Type	Method and Description
void	InMemoryTokenStore.initializeTokenSegments(String processorName, int segmentCount, TrackingToken initialToken)
void	InMemoryTokenStore.storeToken(TrackingToken token, String processorName, int segment)

Uses of TrackingToken in org.axonframework.eventhandling.tokenstore.jdbc

Methods in org.axonframework.eventhandling.tokenstore.jdbc that return TrackingToken

Modifier and Type	Method and Description
protected TrackingToken	JdbcTokenStore.claimToken(ResultSet resultSet, AbstractTokenEntry<?> entry) Tries to claim the given token entry.
TrackingToken	JdbcTokenStore.fetchToken(String processorName, int segment)
protected TrackingToken	JdbcTokenStore.insertTokenEntry(ResultSet resultSet, TrackingToken token, String processorName, int segment) Inserts a new token entry via the given updatable resultSet.
protected TrackingToken	JdbcTokenStore.loadOrInsertToken(ResultSet resultSet, String processorName, int segment) Tries loading an existing token owned by a processor with given processorName and segment.

Methods in org.axonframework.eventhandling.tokenstore.jdbc with parameters of type TrackingToken

Modifier and Type	Method and Description
void	JdbcTokenStore.initializeTokenSegments(String processorName, int segmentCount, TrackingToken initialToken)
protected void	JdbcTokenStore.insertOrUpdateToken(ResultSet resultSet, TrackingToken token, String processorName, int segment) If the given resultSet has no items this method should insert a new token entry.
protected TrackingToken	JdbcTokenStore.insertTokenEntry(ResultSet resultSet, TrackingToken token, String processorName, int segment) Inserts a new token entry via the given updatable resultSet.
void	JdbcTokenStore.storeToken(TrackingToken token, String processorName, int segment)

Uses of TrackingToken in org.axonframework.eventhandling.tokenstore.jpa

Methods in org.axonframework.eventhandling.tokenstore.jpa that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	JpaTokenStore.fetchToken(String processorName, int segment)

Methods in org.axonframework.eventhandling.tokenstore.jpa with parameters of type TrackingToken

Modifier and Type	Method and Description
void	JpaTokenStore.initializeTokenSegments(String processorName, int segmentCount, TrackingToken initialToken)
void	JpaTokenStore.storeToken(TrackingToken token, String processorName, int segment)
void	TokenEntry.updateToken(TrackingToken token, Serializer serializer)

Constructors in org.axonframework.eventhandling.tokenstore.jpa with parameters of type TrackingToken

Constructor and Description
TokenEntry(String processorName, int segment, TrackingToken token, Serializer serializer) Initializes a new token entry for given token, processorName and segment.

Uses of TrackingToken in org.axonframework.eventsourcing

Methods in org.axonframework.eventsourcing that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	FilteringEventStorageEngine.createHeadToken()
TrackingToken	FilteringEventStorageEngine.createTailToken()
TrackingToken	FilteringEventStorageEngine.createTokenAt(Instant dateTime)
TrackingToken	GenericTrackedDomainEventMessage.trackingToken()

Methods in org.axonframework.eventsourcing with parameters of type TrackingToken

Modifier and Type	Method and Description
Stream<? extends TrackedEventMessage<?>>	FilteringEventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock)

Constructors in org.axonframework.eventsourcing with parameters of type TrackingToken

Constructor and Description
GenericTrackedDomainEventMessage(TrackingToken trackingToken, DomainEventMessage<T> delegate) Initialize a DomainEventMessage originating from an aggregate.
GenericTrackedDomainEventMessage(TrackingToken trackingToken, String type, String aggregateIdentifier, long sequenceNumber, Message<T> delegate, Instant timestamp) Initialize a DomainEventMessage originating from an aggregate.
GenericTrackedDomainEventMessage(TrackingToken trackingToken, String type, String aggregateIdentifier, long sequenceNumber, Message<T> delegate, Supplier<Instant> timestamp) Initialize a DomainEventMessage originating from an Aggregate using existing data.

Uses of TrackingToken in org.axonframework.eventsourcing.eventstore

Classes in org.axonframework.eventsourcing.eventstore that implement TrackingToken

Modifier and Type	Class and Description
class	GapAwareTrackingToken Implementation of a TrackingToken that uses the global insertion sequence number of the event to determine tracking order and additionally stores a set of possible gaps that have been detected while tracking the event store.
class	GlobalSequenceTrackingToken Tracking token based on the global sequence number of an event.

Methods in org.axonframework.eventsourcing.eventstore that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	SequenceEventStorageEngine.createHeadToken()
default TrackingToken	EventStorageEngine.createHeadToken() Creates a token that is at the head of an event stream - that tracks all new events.
TrackingToken	AbstractEventStore.createHeadToken()
TrackingToken	SequenceEventStorageEngine.createTailToken()
default TrackingToken	EventStorageEngine.createTailToken() Creates a token that is at the tail of an event stream - that tracks events from the beginning of time.
TrackingToken	AbstractEventStore.createTailToken()
TrackingToken	SequenceEventStorageEngine.createTokenAt(Instant dateTime)
default TrackingToken	EventStorageEngine.createTokenAt(Instant dateTime) Creates a token that tracks all events after given dateTime.
TrackingToken	AbstractEventStore.createTokenAt(Instant dateTime)
TrackingToken	TrackingToken.lowerBound(TrackingToken other) Returns a token that represents the lower bound between this and the other token.
TrackingToken	GlobalSequenceTrackingToken.lowerBound(TrackingToken other)
TrackingToken	TrackedEventData.trackingToken() Returns the TrackingToken of the serialized event.
TrackingToken	TrackedDomainEventData.trackingToken()
TrackingToken	GenericTrackedDomainEventEntry.trackingToken() Deprecated.
TrackingToken	TrackingToken.upperBound(TrackingToken other) Returns the token that represents the furthest possible position in a stream that either this token or the given other represents.
TrackingToken	GlobalSequenceTrackingToken.upperBound(TrackingToken other)
TrackingToken	GapAwareTrackingToken.upperBound(TrackingToken otherToken)

Methods in org.axonframework.eventsourcing.eventstore with parameters of type TrackingToken

Modifier and Type	Method and Description
static <T> TrackedEventMessage<T>	EventUtils.asTrackedEventMessage(EventMessage<T> eventMessage, TrackingToken trackingToken) Convert an EventMessage to a TrackedEventMessage using the given trackingToken.
boolean	TrackingToken.covers(TrackingToken other) Indicates whether this token covers the other token completely.
boolean	GlobalSequenceTrackingToken.covers(TrackingToken other)
boolean	GapAwareTrackingToken.covers(TrackingToken other)
protected abstract List<? extends TrackedEventData<?>>	BatchingEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken, int batchSize) Returns a batch of serialized event data entries in the event storage that have a TrackingToken greater than the given lastToken.
TrackingToken	TrackingToken.lowerBound(TrackingToken other) Returns a token that represents the lower bound between this and the other token.
TrackingToken	GlobalSequenceTrackingToken.lowerBound(TrackingToken other)
GapAwareTrackingToken	GapAwareTrackingToken.lowerBound(TrackingToken other)
TrackingEventStream	EmbeddedEventStore.openStream(TrackingToken trackingToken)
protected Stream<? extends TrackedEventData<?>>	BatchingEventStorageEngine.readEventData(TrackingToken trackingToken, boolean mayBlock) Returns a global Stream containing all serialized event data entries in the event storage that have a TrackingToken greater than the given trackingToken.
protected abstract Stream<? extends TrackedEventData<?>>	AbstractEventStorageEngine.readEventData(TrackingToken trackingToken, boolean mayBlock) Returns a global Stream containing all serialized event data entries in the event storage that have a TrackingToken greater than the given trackingToken.
Stream<? extends TrackedEventMessage<?>>	SequenceEventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock)
Stream<? extends TrackedEventMessage<?>>	EventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock) Open an event stream containing all events stored since given tracking token.
Stream<? extends TrackedEventMessage<?>>	AbstractEventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock)
TrackingToken	TrackingToken.upperBound(TrackingToken other) Returns the token that represents the furthest possible position in a stream that either this token or the given other represents.
TrackingToken	GlobalSequenceTrackingToken.upperBound(TrackingToken other)
TrackingToken	GapAwareTrackingToken.upperBound(TrackingToken otherToken)

Constructors in org.axonframework.eventsourcing.eventstore with parameters of type TrackingToken

Constructor and Description
GenericTrackedDomainEventEntry(TrackingToken trackingToken, String type, String aggregateIdentifier, long sequenceNumber, String eventIdentifier, Object timestamp, String payloadType, String payloadRevision, T payload, T metaData) Deprecated. Reconstruct an event entry from a stored object.
TrackedDomainEventData(TrackingToken trackingToken, DomainEventData<T> domainEventEntry) Initialize the TrackingDomainEventData with given trackingToken and domainEventEntry.

Uses of TrackingToken in org.axonframework.eventsourcing.eventstore.inmemory

Methods in org.axonframework.eventsourcing.eventstore.inmemory that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	InMemoryEventStorageEngine.createHeadToken()
TrackingToken	InMemoryEventStorageEngine.createTailToken()
TrackingToken	InMemoryEventStorageEngine.createTokenAt(Instant dateTime)

Methods in org.axonframework.eventsourcing.eventstore.inmemory with parameters of type TrackingToken

Modifier and Type	Method and Description
Stream<? extends TrackedEventMessage<?>>	InMemoryEventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock) Open an event stream containing all events stored since given tracking token.

Uses of TrackingToken in org.axonframework.eventsourcing.eventstore.jdbc

Methods in org.axonframework.eventsourcing.eventstore.jdbc that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	JdbcEventStorageEngine.createHeadToken()
TrackingToken	JdbcEventStorageEngine.createTailToken()
TrackingToken	JdbcEventStorageEngine.createTokenAt(Instant dateTime)

Methods in org.axonframework.eventsourcing.eventstore.jdbc with parameters of type TrackingToken

Modifier and Type	Method and Description
protected List<? extends TrackedEventData<?>>	JdbcEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken, int batchSize)
protected PreparedStatement	JdbcEventStorageEngine.readEventData(Connection connection, TrackingToken lastToken, int batchSize) Creates a statement to read tracked event entries stored since given tracking token.

Uses of TrackingToken in org.axonframework.eventsourcing.eventstore.jpa

Methods in org.axonframework.eventsourcing.eventstore.jpa that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	JpaEventStorageEngine.createHeadToken()
TrackingToken	JpaEventStorageEngine.createTailToken()
TrackingToken	JpaEventStorageEngine.createTokenAt(Instant dateTime)

Methods in org.axonframework.eventsourcing.eventstore.jpa with parameters of type TrackingToken

Modifier and Type	Method and Description
protected List<? extends TrackedEventData<?>>	JpaEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken, int batchSize)

Uses of TrackingToken in org.axonframework.kafka.eventhandling.consumer

Classes in org.axonframework.kafka.eventhandling.consumer that implement TrackingToken

Modifier and Type	Class and Description
class	KafkaTrackingToken Use to track messages consumed & committed from Kafka to Axon.

Methods in org.axonframework.kafka.eventhandling.consumer that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	KafkaTrackingToken.lowerBound(TrackingToken other)
TrackingToken	KafkaTrackingToken.upperBound(TrackingToken other)

Methods in org.axonframework.kafka.eventhandling.consumer with parameters of type TrackingToken

Modifier and Type	Method and Description
boolean	KafkaTrackingToken.covers(TrackingToken other)
TrackingToken	KafkaTrackingToken.lowerBound(TrackingToken other)
MessageStream<TrackedEventMessage<?>>	KafkaMessageSource.openStream(TrackingToken trackingToken)
TrackingToken	KafkaTrackingToken.upperBound(TrackingToken other)

Uses of TrackingToken in org.axonframework.messaging

Methods in org.axonframework.messaging that return TrackingToken

Modifier and Type	Method and Description
default TrackingToken	StreamableMessageSource.createHeadToken() Creates the token at the end of an event stream.
default TrackingToken	StreamableMessageSource.createTailToken() Creates the token at the beginning of an event stream.
default TrackingToken	StreamableMessageSource.createTokenAt(Instant dateTime) Creates a token that tracks all events after given dateTime.
default TrackingToken	StreamableMessageSource.createTokenSince(Duration duration) Creates a token that tracks all events since the last duration.

Methods in org.axonframework.messaging with parameters of type TrackingToken

Modifier and Type	Method and Description
MessageStream<M>	StreamableMessageSource.openStream(TrackingToken trackingToken) Open a stream containing all messages since given tracking token.

Uses of TrackingToken in org.axonframework.mongo.eventhandling.saga.repository

Methods in org.axonframework.mongo.eventhandling.saga.repository with parameters of type TrackingToken

Modifier and Type	Method and Description
void	MongoSagaStore.insertSaga(Class<?> sagaType, String sagaIdentifier, Object saga, TrackingToken token, Set<AssociationValue> associationValues)
void	MongoSagaStore.updateSaga(Class<?> sagaType, String sagaIdentifier, Object saga, TrackingToken token, AssociationValues associationValues)

Uses of TrackingToken in org.axonframework.mongo.eventsourcing.eventstore

Classes in org.axonframework.mongo.eventsourcing.eventstore that implement TrackingToken

Modifier and Type	Class and Description
class	MongoTrackingToken Tracking token implementation produced by the MongoEventStorageEngine to keep track of the position in an event stream.

Methods in org.axonframework.mongo.eventsourcing.eventstore that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	MongoEventStorageEngine.createHeadToken()
TrackingToken	MongoEventStorageEngine.createTailToken()
TrackingToken	StorageStrategy.createTailToken(com.mongodb.client.MongoCollection<org.bson.Document> eventsCollection) Creates a token that is at the tail of an event stream - that tracks events from the beginning of time.
TrackingToken	AbstractMongoEventStorageStrategy.createTailToken(com.mongodb.client.MongoCollection<org.bson.Document> eventsCollection)
TrackingToken	MongoEventStorageEngine.createTokenAt(Instant dateTime)
TrackingToken	MongoTrackingToken.lowerBound(TrackingToken other)
TrackingToken	MongoTrackingToken.upperBound(TrackingToken other)

Methods in org.axonframework.mongo.eventsourcing.eventstore with parameters of type TrackingToken

Modifier and Type	Method and Description
boolean	MongoTrackingToken.covers(TrackingToken other)
protected List<? extends TrackedEventData<?>>	MongoEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken, int batchSize)
List<? extends TrackedEventData<?>>	StorageStrategy.findTrackedEvents(com.mongodb.client.MongoCollection<org.bson.Document> eventCollection, TrackingToken lastToken, int batchSize) Returns a batch of tracked events with a tracking token above the given lastToken.
List<? extends TrackedEventData<?>>	AbstractMongoEventStorageStrategy.findTrackedEvents(com.mongodb.client.MongoCollection<org.bson.Document> eventCollection, TrackingToken lastToken, int batchSize)
TrackingToken	MongoTrackingToken.lowerBound(TrackingToken other)
TrackingToken	MongoTrackingToken.upperBound(TrackingToken other)

Uses of TrackingToken in org.axonframework.mongo.eventsourcing.tokenstore

Methods in org.axonframework.mongo.eventsourcing.tokenstore that return TrackingToken

Modifier and Type	Method and Description
TrackingToken	MongoTokenStore.fetchToken(String processorName, int segment) Returns the last stored token for the given processorName and segment.

Methods in org.axonframework.mongo.eventsourcing.tokenstore with parameters of type TrackingToken

Modifier and Type	Method and Description
void	MongoTokenStore.initializeTokenSegments(String processorName, int segmentCount, TrackingToken initialToken)
void	MongoTokenStore.storeToken(TrackingToken token, String processorName, int segment)

Uses of TrackingToken in org.axonframework.serialization.upcasting.event

Methods in org.axonframework.serialization.upcasting.event that return types with arguments of type TrackingToken

Modifier and Type	Method and Description
Optional<TrackingToken>	UpcastedEventRepresentation.getTrackingToken()
Optional<TrackingToken>	IntermediateEventRepresentation.getTrackingToken() Returns the tracking token of the event, or an empty Optional if the message wrapping the object being upcast does not contain a tracking token.
Optional<TrackingToken>	InitialEventRepresentation.getTrackingToken()