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.pooled
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

Subinterfaces of TrackingToken in org.axonframework.eventhandling

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

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	MergedTrackingToken Special Wrapped Token implementation that keeps track of two separate tokens, of which the streams have been merged into a single one.
class	MultiSourceTrackingToken Combined tracking token used when processing from multiple event sources
class	ReplayToken Token keeping track of the position before a reset was triggered.

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

Modifier and Type	Method and Description
<R extends TrackingToken> Optional<R>	WrappedToken.unwrap(Class<R> tokenType) Retrieve a token of given tokenType if it is wrapped by this token.
<R extends TrackingToken> Optional<R>	ReplayToken.unwrap(Class<R> tokenType)
<R extends TrackingToken> Optional<R>	MergedTrackingToken.unwrap(Class<R> tokenType)
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.eventhandling that return TrackingToken

Modifier and Type	Method and Description
static TrackingToken	WrappedToken.advance(TrackingToken base, TrackingToken target) Advance the given base TrackingToken to the target.
TrackingToken	WrappedToken.advancedTo(TrackingToken newToken) Advance this token to the given newToken.
TrackingToken	ReplayToken.advancedTo(TrackingToken newToken)
TrackingToken	MergedTrackingToken.advancedTo(TrackingToken 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	TrackerStatus.getInternalTrackingToken() Return the TrackingToken this EventTrackerStatus portrays the status of.
TrackingToken	ReplayToken.getTokenAtReset() Gets the token representing the position at which the reset was triggered.
TrackingToken	MultiSourceTrackingToken.getTokenForStream(String streamName) Return the tracking token for an individual stream
TrackingToken	WrappedTrackerStatus.getTrackingToken()
TrackingToken	TrackerStatus.getTrackingToken()
TrackingToken	EventTrackerStatus.getTrackingToken() The tracking token of the last event that has been seen by this Segment.
TrackingToken	WrappedToken.lowerBound() Returns the token representing the current position in the stream.
TrackingToken	ReplayToken.lowerBound()
TrackingToken	MergedTrackingToken.lowerBound()
TrackingToken	TrackingToken.lowerBound(TrackingToken other) Returns a token that represents the lower bound between this and the other token.
TrackingToken	ReplayToken.lowerBound(TrackingToken other)
TrackingToken	MultiSourceTrackingToken.lowerBound(TrackingToken other) Compares this token to other by comparing each member token with its counterpart in the other token.
TrackingToken	MergedTrackingToken.lowerBound(TrackingToken other)
TrackingToken	GlobalSequenceTrackingToken.lowerBound(TrackingToken other)
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.
TrackingToken	TrackedEventMessage.trackingToken() Returns the TrackingToken of the event message.
TrackingToken	TrackedEventData.trackingToken() Returns the TrackingToken of the serialized event.
TrackingToken	TrackedDomainEventData.trackingToken()
TrackingToken	GenericTrackedEventMessage.trackingToken()
TrackingToken	GenericTrackedDomainEventMessage.trackingToken()
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	WrappedToken.upperBound() Returns the token representing the furthest position in the stream described by this token.
TrackingToken	ReplayToken.upperBound()
TrackingToken	MergedTrackingToken.upperBound()
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	ReplayToken.upperBound(TrackingToken other)
TrackingToken	MultiSourceTrackingToken.upperBound(TrackingToken other) Compares this token to other by comparing each member token with its counterpart in the other token.
TrackingToken	MergedTrackingToken.upperBound(TrackingToken other)
TrackingToken	GlobalSequenceTrackingToken.upperBound(TrackingToken other)
TrackingToken	GapAwareTrackingToken.upperBound(TrackingToken otherToken)
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.eventhandling that return types with arguments of type TrackingToken

Modifier and Type	Method and Description
Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken>	TrackingEventProcessorConfiguration.getInitialTrackingToken()
Map<String,TrackingToken>	MultiSourceTrackingToken.getTrackingTokens() Returns the map containing the constituent tokens.

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

Modifier and Type	Method and Description
static TrackingToken	WrappedToken.advance(TrackingToken base, TrackingToken target) Advance the given base TrackingToken to the target.
MultiSourceTrackingToken	MultiSourceTrackingToken.advancedTo(String streamName, TrackingToken newTokenForStream) Advances a single token within the tokenMap
TrackingToken	WrappedToken.advancedTo(TrackingToken newToken) Advance this token to the given newToken.
TrackerStatus	TrackerStatus.advancedTo(TrackingToken trackingToken) Advance this TrackerStatus' TrackingToken towards the given trackingToken.
TrackingToken	ReplayToken.advancedTo(TrackingToken newToken)
TrackingToken	MergedTrackingToken.advancedTo(TrackingToken newToken)
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	ReplayToken.covers(TrackingToken other)
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.
boolean	MergedTrackingToken.covers(TrackingToken other)
boolean	GlobalSequenceTrackingToken.covers(TrackingToken other)
boolean	GapAwareTrackingToken.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 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.
TrackingToken	TrackingToken.lowerBound(TrackingToken other) Returns a token that represents the lower bound between this and the other token.
TrackingToken	ReplayToken.lowerBound(TrackingToken other)
TrackingToken	MultiSourceTrackingToken.lowerBound(TrackingToken other) Compares this token to other by comparing each member token with its counterpart in the other token.
TrackingToken	MergedTrackingToken.lowerBound(TrackingToken other)
TrackingToken	GlobalSequenceTrackingToken.lowerBound(TrackingToken other)
GapAwareTrackingToken	GapAwareTrackingToken.lowerBound(TrackingToken other)
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.
protected Set<Segment>	TrackingEventProcessor.processingSegments(TrackingToken token, Segment segment) Indicates whether the eventMessage identified with given token should be processed as part of the given segment.
void	TrackingEventProcessor.resetTokens(TrackingToken startPosition)
default void	StreamingEventProcessor.resetTokens(TrackingToken startPosition) Resets tokens to the given startPosition.
<R> void	TrackingEventProcessor.resetTokens(TrackingToken startPosition, R resetContext)
<R> void	StreamingEventProcessor.resetTokens(TrackingToken startPosition, R resetContext) Resets tokens to the given startPosition.
static TrackerStatus[]	TrackerStatus.split(Segment segment, TrackingToken trackingToken) Split the given segment and trackingToken in two.
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	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	ReplayToken.upperBound(TrackingToken other)
TrackingToken	MultiSourceTrackingToken.upperBound(TrackingToken other) Compares this token to other by comparing each member token with its counterpart in the other token.
TrackingToken	MergedTrackingToken.upperBound(TrackingToken other)
TrackingToken	GlobalSequenceTrackingToken.upperBound(TrackingToken other)
TrackingToken	GapAwareTrackingToken.upperBound(TrackingToken otherToken)
TrackedEventMessage<T>	TrackedEventMessage.withTrackingToken(TrackingToken trackingToken) Creates a copy of this message with the given trackingToken to replace the one in this message.
GenericTrackedEventMessage<T>	GenericTrackedEventMessage.withTrackingToken(TrackingToken trackingToken)
GenericTrackedDomainEventMessage<T>	GenericTrackedDomainEventMessage.withTrackingToken(TrackingToken trackingToken)

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

Modifier and Type	Method and Description
TrackingEventProcessorConfiguration	TrackingEventProcessorConfiguration.andInitialTrackingToken(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenBuilder) Sets the Builder to use to create the initial tracking token.
void	TrackingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier)
void	StreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier) Reset tokens to the position as return by the given initialTrackingTokenSupplier.
<R> void	TrackingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier, R resetContext)
<R> void	StreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier, R resetContext) 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.
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.
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)
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.
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.

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

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

Uses of TrackingToken in org.axonframework.eventhandling.pooled

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

Modifier and Type	Method and Description
void	PooledStreamingEventProcessor.resetTokens(TrackingToken startPosition)
<R> void	PooledStreamingEventProcessor.resetTokens(TrackingToken startPosition, R resetContext)

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

Modifier and Type	Method and Description
PooledStreamingEventProcessor.Builder	PooledStreamingEventProcessor.Builder.initialToken(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialToken) Specifies the Function used to generate the initial TrackingTokens.
void	PooledStreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier)
<R> void	PooledStreamingEventProcessor.resetTokens(Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> initialTrackingTokenSupplier, R resetContext)

Uses of TrackingToken in org.axonframework.eventhandling.tokenstore

Classes in org.axonframework.eventhandling.tokenstore that implement TrackingToken

Modifier and Type	Class and 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.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
TrackingToken	ConfigToken.lowerBound(TrackingToken other)
TrackingToken	ConfigToken.upperBound(TrackingToken other)

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

Modifier and Type	Method and Description
boolean	ConfigToken.covers(TrackingToken other)
default void	TokenStore.initializeSegment(TrackingToken token, String processorName, int segment) Initializes a segment with given segment for the processor with given processorName to contain the given token.
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.
TrackingToken	ConfigToken.lowerBound(TrackingToken other)
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.
TrackingToken	ConfigToken.upperBound(TrackingToken other)

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.initializeSegment(TrackingToken token, String processorName, int segment)
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(Connection connection, AbstractTokenEntry<?> entry) Tries to claim the given token entry.
TrackingToken	JdbcTokenStore.fetchToken(String processorName, int segment)
protected TrackingToken	JdbcTokenStore.insertTokenEntry(Connection connection, TrackingToken token, String processorName, int 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.

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

Modifier and Type	Method and Description
void	JdbcTokenStore.initializeSegment(TrackingToken token, String processorName, int segment)
void	JdbcTokenStore.initializeTokenSegments(String processorName, int segmentCount, TrackingToken initialToken)
protected TrackingToken	JdbcTokenStore.insertTokenEntry(Connection connection, 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)
protected PreparedStatement	JdbcTokenStore.storeUpdate(Connection connection, TrackingToken token, String processorName, int segment) Returns a PreparedStatement which updates the given token for the given processorName and segment combination.
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.

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.initializeSegment(TrackingToken token, String processorName, int segment)
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
org.axonframework.eventsourcing.MultiStreamableMessageSource.MultiSourceBlockingStream	MultiStreamableMessageSource.openStream(TrackingToken trackingToken) Opens a stream for each event source at the specified token position.
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 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)

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>	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()