Uses of Interface
org.axonframework.messaging.eventhandling.processing.streaming.token.TrackingToken

Packages that use TrackingToken

Package	Description
org.axonframework.axonserver.connector.event	Part of the Axon Server Connector module.
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	Part of the Axon Eventsourcing module.
org.axonframework.eventsourcing.eventstore.jpa	Part of the Axon Eventsourcing module.
org.axonframework.messaging.eventhandling.processing.streaming	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.pooled	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.segmenting	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.token	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.token.annotation	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.token.store	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.token.store.inmemory	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.token.store.jdbc	Part of the Axon Messaging module.
org.axonframework.messaging.eventhandling.processing.streaming.token.store.jpa	Part of the Axon Messaging module.
org.axonframework.messaging.eventstreaming	Part of the Axon Messaging module.
org.axonframework.test.fixture	Part of the Axon Test module.

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

Methods in org.axonframework.axonserver.connector.event that return types with arguments of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	AggregateBasedAxonServerEventStorageEngine.firstToken()
CompletableFuture<TrackingToken>	AxonServerEventStorageEngine.firstToken()
CompletableFuture<TrackingToken>	AggregateBasedAxonServerEventStorageEngine.latestToken()
CompletableFuture<TrackingToken>	AxonServerEventStorageEngine.latestToken()
CompletableFuture<TrackingToken>	AggregateBasedAxonServerEventStorageEngine.tokenAt(Instant at)
CompletableFuture<TrackingToken>	AxonServerEventStorageEngine.tokenAt(Instant at)

Uses of TrackingToken in org.axonframework.eventsourcing.eventstore

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

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	EventStorageEngine.firstToken()	Creates a TrackingToken that is at the first position of an event stream.
CompletableFuture<TrackingToken>	InterceptingEventStore.firstToken(@Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	StorageEngineBackedEventStore.firstToken(@Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	EventStorageEngine.latestToken()	Creates a TrackingToken that is at the latest position of an event stream.
CompletableFuture<TrackingToken>	InterceptingEventStore.latestToken(@Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	StorageEngineBackedEventStore.latestToken(@Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	EventStorageEngine.tokenAt(Instant at)	Creates a TrackingToken that tracks all events after the given at.
CompletableFuture<TrackingToken>	InterceptingEventStore.tokenAt(Instant at, @Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	StorageEngineBackedEventStore.tokenAt(Instant at, @Nullable ProcessingContext context)

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

Methods in org.axonframework.eventsourcing.eventstore.inmemory that return types with arguments of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	InMemoryEventStorageEngine.firstToken()
CompletableFuture<TrackingToken>	InMemoryEventStorageEngine.latestToken()
CompletableFuture<TrackingToken>	InMemoryEventStorageEngine.tokenAt(Instant at)

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

Methods in org.axonframework.eventsourcing.eventstore.jpa that return types with arguments of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	AggregateBasedJpaEventStorageEngine.firstToken()
CompletableFuture<TrackingToken>	AggregateBasedJpaEventStorageEngine.latestToken()
CompletableFuture<TrackingToken>	AggregateBasedJpaEventStorageEngine.tokenAt(Instant at)

Uses of TrackingToken in org.axonframework.messaging.eventhandling.processing.streaming

Methods in org.axonframework.messaging.eventhandling.processing.streaming with parameters of type TrackingToken

Modifier and Type	Method	Description
default CompletableFuture<Void>	StreamingEventProcessor.resetTokens(TrackingToken startPosition)	Resets tokens to the given startPosition.
<R> CompletableFuture<Void>	StreamingEventProcessor.resetTokens(TrackingToken startPosition, @Nullable R resetContext)	Resets tokens to the given startPosition.

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

Modifier and Type	Method	Description
CompletableFuture<Void>	StreamingEventProcessor.resetTokens(Function<TrackingTokenSource,CompletableFuture<TrackingToken>> initialTrackingTokenSupplier)	Reset tokens to the position as return by the given initialTrackingTokenSupplier.
<R> CompletableFuture<Void>	StreamingEventProcessor.resetTokens(Function<TrackingTokenSource,CompletableFuture<TrackingToken>> initialTrackingTokenSupplier, @Nullable R resetContext)	Reset tokens to the position as return by the given initialTrackingTokenSupplier.

Uses of TrackingToken in org.axonframework.messaging.eventhandling.processing.streaming.pooled

Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled that return types with arguments of type TrackingToken

Modifier and Type	Method	Description
Function<TrackingTokenSource,CompletableFuture<TrackingToken>>	PooledStreamingEventProcessorConfiguration.initialToken()	Returns the function used to generate initial TrackingTokens.

Methods in org.axonframework.messaging.eventhandling.processing.streaming.pooled with parameters of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<Void>	PooledStreamingEventProcessor.resetTokens(TrackingToken startPosition)
<R> CompletableFuture<Void>	PooledStreamingEventProcessor.resetTokens(TrackingToken startPosition, @Nullable R resetContext)

Method parameters in org.axonframework.messaging.eventhandling.processing.streaming.pooled with type arguments of type TrackingToken

Modifier and Type	Method	Description
PooledStreamingEventProcessorConfiguration	PooledStreamingEventProcessorConfiguration.initialToken(Function<TrackingTokenSource,CompletableFuture<TrackingToken>> initialToken)	Specifies the Function used to generate the initial TrackingTokens.
CompletableFuture<Void>	PooledStreamingEventProcessor.resetTokens(Function<TrackingTokenSource,CompletableFuture<TrackingToken>> initialTrackingTokenSupplier)
<R> CompletableFuture<Void>	PooledStreamingEventProcessor.resetTokens(Function<TrackingTokenSource,CompletableFuture<TrackingToken>> initialTrackingTokenSupplier, R resetContext)

Uses of TrackingToken in org.axonframework.messaging.eventhandling.processing.streaming.segmenting

Methods in org.axonframework.messaging.eventhandling.processing.streaming.segmenting that return TrackingToken

Modifier and Type	Method	Description
TrackingToken	TrackerStatus.getInternalTrackingToken()	Return the TrackingToken this EventTrackerStatus portrays the status of.
TrackingToken	EventTrackerStatus.getTrackingToken()	The tracking token of the last event that has been seen by this Segment.
TrackingToken	TrackerStatus.getTrackingToken()
TrackingToken	WrappedTrackerStatus.getTrackingToken()

Methods in org.axonframework.messaging.eventhandling.processing.streaming.segmenting with parameters of type TrackingToken

Modifier and Type	Method	Description
TrackerStatus	TrackerStatus.advancedTo(TrackingToken trackingToken)	Advance this TrackerStatus' TrackingToken towards the given trackingToken.
static TrackerStatus[]	TrackerStatus.split(Segment segment, TrackingToken trackingToken)	Split the given segment and trackingToken in two.

Constructors in org.axonframework.messaging.eventhandling.processing.streaming.segmenting with parameters of type TrackingToken

Modifier	Constructor	Description
	TrackerStatus(Segment segment, boolean caughtUp, TrackingToken trackingToken, Throwable errorState)	Construct a EventTrackerStatus to portray the status of the given segment and trackingToken.
	TrackerStatus(Segment segment, TrackingToken trackingToken)	Construct a EventTrackerStatus to portray the status of the given segment and trackingToken.

Uses of TrackingToken in org.axonframework.messaging.eventhandling.processing.streaming.token

Subinterfaces of TrackingToken in org.axonframework.messaging.eventhandling.processing.streaming.token

Modifier and Type	Interface	Description
interface	WrappedToken	Interface marking a token that wraps another token.

Classes in org.axonframework.messaging.eventhandling.processing.streaming.token that implement TrackingToken

Modifier and Type	Class	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	MergedTrackingToken	Special Wrapped Token implementation that keeps track of two separate tokens, of which the streams have been merged into a single one.
class	ReplayToken	Token keeping track of the position before a reset was triggered.

Fields in org.axonframework.messaging.eventhandling.processing.streaming.token declared as TrackingToken

Modifier and Type	Field	Description
static final TrackingToken	TrackingToken.FIRST	A special TrackingToken that indicates the very beginning of an event stream.
static final TrackingToken	TrackingToken.LATEST	A special TrackingToken that represents the latest (tail) position in an event stream.

Fields in org.axonframework.messaging.eventhandling.processing.streaming.token with type parameters of type TrackingToken

Modifier and Type	Field	Description
static final Context.ResourceKey<TrackingToken>	TrackingToken.RESOURCE_KEY	The Context.ResourceKey used whenever a Context would contain a TrackingToken.

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token with type parameters of type TrackingToken

Modifier and Type	Method	Description
<R extends TrackingToken> Optional<R>	MergedTrackingToken.unwrap(Class<R> tokenType)
<R extends TrackingToken> Optional<R>	ReplayToken.unwrap(Class<R> tokenType)
<R extends TrackingToken> Optional<R>	WrappedToken.unwrap(Class<R> tokenType)	Retrieve a token of given tokenType if it is wrapped by this token.
static <R extends TrackingToken> Optional<R>	WrappedToken.unwrap(TrackingToken token, Class<R> tokenType)	Unwrap the given token until a token of given tokenType is exposed.

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token that return TrackingToken

Modifier and Type	Method	Description
static TrackingToken	WrappedToken.advance(TrackingToken base, TrackingToken target)	Advance the given base TrackingToken to the target.
TrackingToken	MergedTrackingToken.advancedTo(TrackingToken newToken)
TrackingToken	ReplayToken.advancedTo(TrackingToken newToken)
TrackingToken	WrappedToken.advancedTo(TrackingToken newToken)	Advance this token to the given newToken.
static TrackingToken	ReplayToken.createReplayToken(@Nullable TrackingToken tokenAtReset)	Creates a new TrackingToken that represents the tail of the stream.
static @Nullable TrackingToken	ReplayToken.createReplayToken(@Nullable TrackingToken tokenAtReset, @Nullable TrackingToken startPosition)	Creates a new TrackingToken that represents the given startPosition of a stream.
static @Nullable TrackingToken	ReplayToken.createReplayToken(@Nullable TrackingToken tokenAtReset, @Nullable TrackingToken startPosition, byte[] resetContext)	Creates a new TrackingToken that represents the given startPosition of a stream.
TrackingToken	ReplayToken.getCurrentToken()	Gets the current token.
TrackingToken	ReplayToken.getTokenAtReset()	Gets the token representing the position at which the reset was triggered.
TrackingToken	GlobalSequenceTrackingToken.lowerBound(TrackingToken other)
TrackingToken	MergedTrackingToken.lowerBound()
TrackingToken	MergedTrackingToken.lowerBound(TrackingToken other)
TrackingToken	ReplayToken.lowerBound()
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	WrappedToken.lowerBound()	Returns the token representing the current position in the stream.
TrackingToken	MergedTrackingToken.lowerSegmentToken()	Returns the token indicating the progress of the lower half (the half with the lower segmentId) of the merged segment represented by this token
static TrackingToken	MergedTrackingToken.merged(TrackingToken lowerSegmentToken, TrackingToken upperSegmentToken)	Create a merged token using the given lowerSegmentToken and upperSegmentToken.
static TrackingToken	WrappedToken.unwrapLowerBound(TrackingToken token)	Extracts a raw token describing the current processing position of the given token.
static TrackingToken	WrappedToken.unwrapUpperBound(TrackingToken token)	Extracts a raw token describing the current processing position of the given token.
TrackingToken	GapAwareTrackingToken.upperBound(TrackingToken otherToken)
TrackingToken	GlobalSequenceTrackingToken.upperBound(TrackingToken other)
TrackingToken	MergedTrackingToken.upperBound()
TrackingToken	MergedTrackingToken.upperBound(TrackingToken other)
TrackingToken	ReplayToken.upperBound()
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.
TrackingToken	WrappedToken.upperBound()	Returns the token representing the furthest position in the stream described by this token.
TrackingToken	MergedTrackingToken.upperSegmentToken()	Returns the token indicating the progress of the upper half (the half with the higher segmentId) of the merged segment represented by this token

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token that return types with arguments of type TrackingToken

Modifier and Type	Method	Description
static Optional<TrackingToken>	TrackingToken.fromContext(Context context)	Returns an Optional of {TrackingToken}, returning the resource keyed under the RESOURCE_KEY in the given context.

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token with parameters of type TrackingToken

Modifier and Type	Method	Description
static Context	TrackingToken.addToContext(Context context, TrackingToken token)	Adds the given token to the given context using the RESOURCE_KEY.
static TrackingToken	WrappedToken.advance(TrackingToken base, TrackingToken target)	Advance the given base TrackingToken to the target.
TrackingToken	MergedTrackingToken.advancedTo(TrackingToken newToken)
TrackingToken	ReplayToken.advancedTo(TrackingToken newToken)
TrackingToken	WrappedToken.advancedTo(TrackingToken newToken)	Advance this token to the given newToken.
static boolean	ReplayToken.concludesReplay(TrackingToken trackingToken)	Indicates whether the given trackingToken is (1) a ReplayToken and (2) will conclude the replay.
boolean	GapAwareTrackingToken.covers(TrackingToken other)
boolean	GlobalSequenceTrackingToken.covers(TrackingToken other)
boolean	MergedTrackingToken.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(@Nullable TrackingToken tokenAtReset)	Creates a new TrackingToken that represents the tail of the stream.
static @Nullable TrackingToken	ReplayToken.createReplayToken(@Nullable TrackingToken tokenAtReset, @Nullable TrackingToken startPosition)	Creates a new TrackingToken that represents the given startPosition of a stream.
static @Nullable TrackingToken	ReplayToken.createReplayToken(@Nullable TrackingToken tokenAtReset, @Nullable TrackingToken startPosition, byte[] resetContext)	Creates a new TrackingToken that represents the given startPosition of a stream.
static OptionalLong	ReplayToken.getTokenAtReset(TrackingToken trackingToken)	Return the relative position at which a reset was triggered for this Segment.
static boolean	MergedTrackingToken.isMergeInProgress(TrackingToken trackingToken)	Indicates whether the given trackingToken represents a token that is part of a merge.
static boolean	ReplayToken.isReplay(TrackingToken trackingToken)	Indicates whether the given trackingToken represents a position that is part of a replay.
GapAwareTrackingToken	GapAwareTrackingToken.lowerBound(TrackingToken other)
TrackingToken	GlobalSequenceTrackingToken.lowerBound(TrackingToken other)
TrackingToken	MergedTrackingToken.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.
static TrackingToken	MergedTrackingToken.merged(TrackingToken lowerSegmentToken, TrackingToken upperSegmentToken)	Create a merged token using the given lowerSegmentToken and upperSegmentToken.
static OptionalLong	MergedTrackingToken.mergePosition(TrackingToken trackingToken)	Return the estimated relative token position this Segment will have after a merge operation is complete.
static <T> Optional<T>	ReplayToken.replayContext(TrackingToken token, Class<T> type, Converter converter)	Extracts the ReplayToken.resetContext() from the given token, converting it to the given type with the given converter.
boolean	GapAwareTrackingToken.samePositionAs(TrackingToken other)	Indicates whether this token is at the exact same spot in the event stream as the other token.
boolean	GlobalSequenceTrackingToken.samePositionAs(TrackingToken other)
boolean	MergedTrackingToken.samePositionAs(TrackingToken other)
boolean	ReplayToken.samePositionAs(TrackingToken other)
default boolean	TrackingToken.samePositionAs(TrackingToken other)	Indicates whether this token is at the exact same spot in the event stream as the other token.
static <R extends TrackingToken> Optional<R>	WrappedToken.unwrap(TrackingToken token, Class<R> tokenType)	Unwrap the given token until a token of given tokenType is exposed.
static TrackingToken	WrappedToken.unwrapLowerBound(TrackingToken token)	Extracts a raw token describing the current processing position of the given token.
static TrackingToken	WrappedToken.unwrapUpperBound(TrackingToken token)	Extracts a raw token describing the current processing position of the given token.
TrackingToken	GapAwareTrackingToken.upperBound(TrackingToken otherToken)
TrackingToken	GlobalSequenceTrackingToken.upperBound(TrackingToken other)
TrackingToken	MergedTrackingToken.upperBound(TrackingToken other)
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.

Constructors in org.axonframework.messaging.eventhandling.processing.streaming.token with parameters of type TrackingToken

Modifier	Constructor	Description
	MergedTrackingToken(TrackingToken lowerSegmentToken, TrackingToken upperSegmentToken)	Initialize a Merged Token, with the lowerSegmentToken representing the progress of the segment with the lower segmentId, and upperSegmentToken representing the progress of the segment with the higher segmentId.
protected	MergedTrackingToken(TrackingToken lowerSegmentToken, TrackingToken upperSegmentToken, boolean lowerSegmentAdvanced, boolean upperSegmentAdvanced)	Initialize a Merged Token, with the lowerSegmentToken representing the progress of the segment with the lower segmentId, and upperSegmentToken representing the progress of the segment with the higher segmentId, additionally indicating if either of these segments were advanced by the latest call to MergedTrackingToken.advancedTo(TrackingToken)

Uses of TrackingToken in org.axonframework.messaging.eventhandling.processing.streaming.token.annotation

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.annotation that return types with arguments of type TrackingToken

Modifier and Type	Method	Description
@Nullable ParameterResolver<TrackingToken>	TrackingTokenParameterResolverFactory.createInstance(Executable executable, Parameter[] parameters, int parameterIndex)

Uses of TrackingToken in org.axonframework.messaging.eventhandling.processing.streaming.token.store

Classes in org.axonframework.messaging.eventhandling.processing.streaming.token.store that implement TrackingToken

Modifier and Type	Class	Description
class	ConfigToken	A special implementation of a Token that is used to store configuration specific to the underlying storage of each TokenStore instance.

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store that return TrackingToken

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

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store that return types with arguments of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	TokenStore.fetchToken(String processorName, int segmentId, @Nullable ProcessingContext context)	Fetches the last stored token for the given processorName and segmentId.
default CompletableFuture<TrackingToken>	TokenStore.fetchToken(String processorName, Segment segment, @Nullable ProcessingContext context)	Fetches the last stored token for the given processorName and segment.

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store with parameters of type TrackingToken

Modifier and Type	Method	Description
boolean	ConfigToken.covers(TrackingToken other)
CompletableFuture<Void>	TokenStore.initializeSegment(@Nullable TrackingToken token, String processorName, Segment segment, @Nullable ProcessingContext context)	Initializes a segment with given segment for the processor with given processorName to contain the given token.
CompletableFuture<List<Segment>>	TokenStore.initializeTokenSegments(String processorName, int segmentCount, @Nullable TrackingToken initialToken, @Nullable ProcessingContext context)	Initializes a given number of segments for the given processorName to track its tokens.
TrackingToken	ConfigToken.lowerBound(TrackingToken other)
boolean	ConfigToken.samePositionAs(TrackingToken other)
CompletableFuture<Void>	TokenStore.storeToken(@Nullable TrackingToken token, String processorName, int segmentId, @Nullable ProcessingContext context)	Stores the given token in the store.
TrackingToken	ConfigToken.upperBound(TrackingToken other)

Uses of TrackingToken in org.axonframework.messaging.eventhandling.processing.streaming.token.store.inmemory

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.inmemory that return types with arguments of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	InMemoryTokenStore.fetchToken(String processorName, int segmentId, @Nullable ProcessingContext context)

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.inmemory with parameters of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<Void>	InMemoryTokenStore.initializeSegment(@Nullable TrackingToken token, String processorName, Segment segment, @Nullable ProcessingContext context)
CompletableFuture<List<Segment>>	InMemoryTokenStore.initializeTokenSegments(String processorName, int segmentCount, @Nullable TrackingToken initialToken, @Nullable ProcessingContext context)
CompletableFuture<Void>	InMemoryTokenStore.storeToken(@Nullable TrackingToken token, String processorName, int segmentId, @Nullable ProcessingContext context)

Uses of TrackingToken in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jdbc

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jdbc that return TrackingToken

Modifier and Type	Method	Description
protected TrackingToken	JdbcTokenStore.claimToken(Connection connection, JdbcTokenEntry entry)	Tries to claim the given token entry.
TrackingToken	JdbcTokenEntry.getToken(Converter converter)	Returns the token, deserializing it with given converter.
protected TrackingToken	JdbcTokenStore.insertTokenEntry(Connection connection, TrackingToken token, String processorName, Segment segment)	Inserts a new token entry via the given updatable resultSet.
protected TrackingToken	JdbcTokenStore.loadToken(Connection connection, ResultSet resultSet, String processorName, int segment)	Tries loading an existing token owned by a processor with given processorName and segment.
protected TrackingToken	JdbcTokenStore.loadToken(Connection connection, ResultSet resultSet, String processorName, Segment segment)	Tries to load an existing token owned by a processor with given processorName and segment.

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jdbc that return types with arguments of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	JdbcTokenStore.fetchToken(String processorName, int segment, @Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	JdbcTokenStore.fetchToken(String processorName, Segment segment, @Nullable ProcessingContext context)

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jdbc with parameters of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<Void>	JdbcTokenStore.initializeSegment(@Nullable TrackingToken token, String processorName, Segment segment, @Nullable ProcessingContext context)
CompletableFuture<List<Segment>>	JdbcTokenStore.initializeTokenSegments(String processorName, int segmentCount, @Nullable TrackingToken initialToken, @Nullable ProcessingContext context)
protected TrackingToken	JdbcTokenStore.insertTokenEntry(Connection connection, TrackingToken token, String processorName, Segment segment)	Inserts a new token entry via the given updatable resultSet.
CompletableFuture<Void>	JdbcTokenStore.storeToken(@Nullable TrackingToken token, String processorName, int segment, @Nullable ProcessingContext context)
protected PreparedStatement	JdbcTokenStore.storeUpdate(Connection connection, TrackingToken token, String processorName, int segment)	Returns a PreparedStatement which update the given token for the given processorName and segment combination.
final void	JdbcTokenEntry.updateToken(@Nullable TrackingToken token, Converter converter)	Update the token data to the given token, using given converter to serialize it to bytes[].
protected void	JdbcTokenStore.updateToken(Connection connection, ResultSet resultSet, TrackingToken token, String processorName, int segment)	If the given resultSet has an entry, attempts to replace the token in the entry with the given token and claim ownership.

Constructors in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jdbc with parameters of type TrackingToken

Modifier	Constructor	Description
	JdbcTokenEntry(@Nullable TrackingToken token, Converter converter)	Initializes a new token entry for given token, process and segment.

Uses of TrackingToken in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jpa

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jpa that return TrackingToken

Modifier and Type	Method	Description
TrackingToken	TokenEntry.getToken(Converter converter)	Returns the token, deserializing it with given serializer

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jpa that return types with arguments of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	JpaTokenStore.fetchToken(String processorName, int segment, @Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	JpaTokenStore.fetchToken(String processorName, Segment segment, @Nullable ProcessingContext context)

Methods in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jpa with parameters of type TrackingToken

Modifier and Type	Method	Description
CompletableFuture<Void>	JpaTokenStore.initializeSegment(@Nullable TrackingToken token, String processorName, Segment segment, @Nullable ProcessingContext context)
CompletableFuture<List<Segment>>	JpaTokenStore.initializeTokenSegments(String processorName, int segmentCount, @Nullable TrackingToken initialToken, @Nullable ProcessingContext context)
CompletableFuture<Void>	JpaTokenStore.storeToken(@Nullable TrackingToken token, String processorName, int segment, @Nullable ProcessingContext context)
void	TokenEntry.updateToken(@Nullable TrackingToken token, Converter converter)	Updates a token, using the provided token and serializer to update the serialized token and token type.

Constructors in org.axonframework.messaging.eventhandling.processing.streaming.token.store.jpa with parameters of type TrackingToken

Modifier	Constructor	Description
	TokenEntry(String processorName, Segment segment, @Nullable TrackingToken token, Converter converter)	Initializes a new token entry for given token, processorName and segment.

Uses of TrackingToken in org.axonframework.messaging.eventstreaming

Classes in org.axonframework.messaging.eventstreaming that implement TrackingToken

Modifier and Type	Class	Description
class	MultiSourceTrackingToken	A TrackingToken implementation combining several TrackingTokens into one.

Methods in org.axonframework.messaging.eventstreaming that return TrackingToken

Modifier and Type	Method	Description
TrackingToken	MultiSourceTrackingToken.getTokenForStream(String streamName)	Return the tracking token for an individual stream
TrackingToken	MultiSourceTrackingToken.lowerBound(TrackingToken other)	Compares this token to other by comparing each member token with its counterpart in the other token.
TrackingToken	StreamingCondition.position()	The position as a TrackingToken to start streaming from.

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

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	MultiStreamableEventSource.firstToken(@Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	TrackingTokenSource.firstToken(@Nullable ProcessingContext context)	Creates a TrackingToken representing the first position of the event stream.
Map<String,TrackingToken>	MultiSourceTrackingToken.getTrackingTokens()	Returns the map containing the constituent tokens.
CompletableFuture<TrackingToken>	MultiStreamableEventSource.latestToken(@Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	TrackingTokenSource.latestToken(@Nullable ProcessingContext context)	Creates a TrackingToken representing the latest position, thus pointing at the next event of the event stream.
CompletableFuture<TrackingToken>	MultiStreamableEventSource.tokenAt(Instant at, @Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	TrackingTokenSource.tokenAt(Instant at, @Nullable ProcessingContext context)	Creates a TrackingToken tracking all events after the given at from an event stream.

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

Modifier and Type	Method	Description
MultiSourceTrackingToken	MultiSourceTrackingToken.advancedTo(String streamName, TrackingToken newTokenForStream)	Advances a single token within the tokenMap
static StreamingCondition	StreamingCondition.conditionFor(TrackingToken position, EventCriteria criteria)	Constructs a simple StreamingCondition that starts streaming from the given position, only returning events matching the given criteria.
boolean	MultiSourceTrackingToken.covers(TrackingToken other)	Compares this token to other checking each member token with its counterpart to see if they are covered in the other token.
TrackingToken	MultiSourceTrackingToken.lowerBound(TrackingToken other)	Compares this token to other by comparing each member token with its counterpart in the other token.
boolean	MultiSourceTrackingToken.samePositionAs(TrackingToken other)
static StreamingCondition	StreamingCondition.startingFrom(@Nullable TrackingToken position)	Constructs a simple StreamingCondition that starts streaming from the given position.
MultiSourceTrackingToken	MultiSourceTrackingToken.upperBound(TrackingToken other)	Compares this token to other by comparing each member token with its counterpart in the other token.

Constructor parameters in org.axonframework.messaging.eventstreaming with type arguments of type TrackingToken

Modifier	Constructor	Description
	MultiSourceTrackingToken(Map<String,TrackingToken> trackingTokens)	Construct a new MultiSourceTrackingToken from a map of existing tokens.

Uses of TrackingToken in org.axonframework.test.fixture

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

Modifier and Type	Method	Description
CompletableFuture<TrackingToken>	RecordingEventStore.firstToken(@Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	RecordingEventStore.latestToken(@Nullable ProcessingContext context)
CompletableFuture<TrackingToken>	RecordingEventStore.tokenAt(Instant at, @Nullable ProcessingContext context)