Uses of Interface
org.axonframework.eventhandling.TrackingToken

Packages that use TrackingToken

Package	Description
org.axonframework.axonserver.connector.event.axon
org.axonframework.eventhandling	Classes related to event handling and dispatching, such as Event Listeners and the Event Bus.
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.messaging	Classes related to message processing in Axon Framework.
org.axonframework.serialization.upcasting.event

Uses of TrackingToken in org.axonframework.axonserver.connector.event.axon

Methods in org.axonframework.axonserver.connector.event.axon with parameters of type TrackingToken

Modifier and Type	Method and Description
TrackingEventStream	AxonServerEventStore.openStream(TrackingToken trackingToken)

Uses of TrackingToken in org.axonframework.eventhandling

Classes in org.axonframework.eventhandling 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.
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	GlobalSequenceTrackingToken.lowerBound(TrackingToken other)
TrackingToken	ReplayToken.lowerBound(TrackingToken other)
TrackingToken	TrackingToken.lowerBound(TrackingToken other) Returns a token that represents the lower bound between this and the other token.
TrackingToken	GenericTrackedDomainEventMessage.trackingToken()
TrackingToken	TrackedEventMessage.trackingToken() Returns the TrackingToken of the event message.
TrackingToken	TrackedDomainEventData.trackingToken()
TrackingToken	GenericTrackedEventMessage.trackingToken()
TrackingToken	TrackedEventData.trackingToken() Returns the TrackingToken of the serialized event.
TrackingToken	ReplayToken.unwrap()
TrackingToken	WrappedToken.unwrap() Returns the token representing the current position in the stream.
TrackingToken	GlobalSequenceTrackingToken.upperBound(TrackingToken other)
TrackingToken	GapAwareTrackingToken.upperBound(TrackingToken otherToken)
TrackingToken	ReplayToken.upperBound(TrackingToken other)
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.

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.
static <T> TrackedEventMessage<T>	EventUtils.asTrackedEventMessage(EventMessage<T> eventMessage, TrackingToken trackingToken) Convert an EventMessage to a TrackedEventMessage using the given trackingToken.
boolean	GlobalSequenceTrackingToken.covers(TrackingToken other)
boolean	GapAwareTrackingToken.covers(TrackingToken other)
boolean	ReplayToken.covers(TrackingToken other)
boolean	TrackingToken.covers(TrackingToken other) Indicates whether this token covers the other token completely.
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	GlobalSequenceTrackingToken.lowerBound(TrackingToken other)
GapAwareTrackingToken	GapAwareTrackingToken.lowerBound(TrackingToken other)
TrackingToken	ReplayToken.lowerBound(TrackingToken other)
TrackingToken	TrackingToken.lowerBound(TrackingToken other) Returns a token that represents the lower bound between this and the other token.
void	TrackingEventProcessor.resetTokens(TrackingToken startPosition) Resets tokens to the given startPosition.
TrackingToken	GlobalSequenceTrackingToken.upperBound(TrackingToken other)
TrackingToken	GapAwareTrackingToken.upperBound(TrackingToken otherToken)
TrackingToken	ReplayToken.upperBound(TrackingToken other)
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.

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
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.
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.
TrackedDomainEventData(TrackingToken trackingToken, DomainEventData<T> domainEventEntry) Initialize the TrackingDomainEventData with given trackingToken and domainEventEntry.

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)

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)

Uses of TrackingToken in org.axonframework.eventsourcing.eventstore

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)

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

Modifier and Type	Method and Description
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.
TrackingEventStream	EmbeddedEventStore.openStream(TrackingToken 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.
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.
Stream<? extends TrackedEventMessage<?>>	AbstractEventStorageEngine.readEvents(TrackingToken trackingToken, boolean mayBlock)
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.

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.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
BlockingStream<M>	StreamableMessageSource.openStream(TrackingToken trackingToken) Open a stream containing all messages since given tracking token.

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>	InitialEventRepresentation.getTrackingToken()
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.