Uses of Interface
org.axonframework.messaging.eventstreaming.TrackingTokenSource

Packages that use TrackingTokenSource

Package	Description
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.messaging.eventhandling.processing.streaming
org.axonframework.messaging.eventhandling.processing.streaming.pooled
org.axonframework.messaging.eventstreaming
org.axonframework.test.fixture

Uses of TrackingTokenSource in org.axonframework.eventsourcing.eventstore

Subinterfaces of TrackingTokenSource in org.axonframework.eventsourcing.eventstore

Modifier and Type	Interface	Description
interface	EventStore	Infrastructure component providing the means to start an EventStoreTransaction to append events and event source models from the underlying storage solution.

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

Modifier and Type	Class	Description
class	InterceptingEventStore	Decorator around the EventStore intercepting all events before they are appended or published with dispatch interceptors.
class	StorageEngineBackedEventStore	An EventStore implementation which uses an EventStorageEngine as its storage solution.

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

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

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, R resetContext)	Reset tokens to the position as return by the given initialTrackingTokenSupplier.

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

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

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

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

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 TrackingTokenSource in org.axonframework.messaging.eventstreaming

Subinterfaces of TrackingTokenSource in org.axonframework.messaging.eventstreaming

Modifier and Type	Interface	Description
interface	StreamableEventSource	Interface towards a streamable event source.

Uses of TrackingTokenSource in org.axonframework.test.fixture

Classes in org.axonframework.test.fixture that implement TrackingTokenSource

Modifier and Type	Class	Description
class	RecordingEventStore	An EventStore implementation recording all the events that are published.