Modifier and Type | Method and Description |
---|---|
TrackingEventStream |
AxonServerEventStore.openStream(TrackingToken trackingToken) |
Modifier and Type | Interface and Description |
---|---|
interface |
WrappedToken
Interface marking a token that wraps another token.
|
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.
|
Modifier and Type | Method and Description |
---|---|
<R extends TrackingToken> |
MergedTrackingToken.unwrap(Class<R> tokenType) |
<R extends TrackingToken> |
ReplayToken.unwrap(Class<R> tokenType) |
<R extends TrackingToken> |
WrappedToken.unwrap(Class<R> tokenType)
Retrieve a token of given
tokenType if it is wrapped by this token. |
static <R extends TrackingToken> |
WrappedToken.unwrap(TrackingToken token,
Class<R> tokenType)
Unwrap the given
token until a token of given tokenType is exposed. |
Modifier and Type | Method and Description |
---|---|
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(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 |
MultiSourceTrackingToken.getTokenForStream(String streamName)
Return the tracking token for an individual stream
|
TrackingToken |
EventTrackerStatus.getTrackingToken()
The tracking token of the last event that has been seen by this Segment.
|
TrackingToken |
MergedTrackingToken.lowerBound() |
TrackingToken |
ReplayToken.lowerBound() |
TrackingToken |
WrappedToken.lowerBound()
Returns the token representing the current position in the stream.
|
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 |
ReplayToken.lowerBound(TrackingToken other) |
TrackingToken |
TrackingToken.lowerBound(TrackingToken other)
Returns a token that represents the lower bound between this and the
other token. |
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
|
TrackingToken |
TrackedEventData.trackingToken()
Returns the
TrackingToken of the serialized event. |
TrackingToken |
GenericTrackedDomainEventMessage.trackingToken() |
TrackingToken |
TrackedDomainEventData.trackingToken() |
TrackingToken |
TrackedEventMessage.trackingToken()
Returns the
TrackingToken of the event message. |
TrackingToken |
GenericTrackedEventMessage.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 |
MergedTrackingToken.upperBound() |
TrackingToken |
ReplayToken.upperBound() |
TrackingToken |
WrappedToken.upperBound()
Returns the token representing the furthest position in the stream described by this token.
|
TrackingToken |
GapAwareTrackingToken.upperBound(TrackingToken otherToken) |
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 |
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 |
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
|
Modifier and Type | Method and Description |
---|---|
Function<StreamableMessageSource<TrackedEventMessage<?>>,TrackingToken> |
TrackingEventProcessorConfiguration.getInitialTrackingToken() |
Map<String,TrackingToken> |
MultiSourceTrackingToken.getTrackingTokens()
Returns the map containing the constituent tokens.
|
Modifier and Type | Method and Description |
---|---|
MultiSourceTrackingToken |
MultiSourceTrackingToken.advancedTo(String streamName,
TrackingToken newTokenForStream)
Advances a single token within the tokenMap
|
TrackingToken |
MergedTrackingToken.advancedTo(TrackingToken newToken) |
TrackingToken |
ReplayToken.advancedTo(TrackingToken newToken) |
TrackingToken |
WrappedToken.advancedTo(TrackingToken newToken)
Advance this token to the given
newToken . |
static <T> TrackedEventMessage<T> |
EventUtils.asTrackedEventMessage(EventMessage<T> eventMessage,
TrackingToken trackingToken)
|
boolean |
GapAwareTrackingToken.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 |
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 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 |
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 |
ReplayToken.lowerBound(TrackingToken other) |
TrackingToken |
TrackingToken.lowerBound(TrackingToken other)
Returns a token that represents the lower bound between this and the
other token. |
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)
Resets tokens to the given
startPosition . |
static <R extends TrackingToken> |
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 |
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 |
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. |
GenericTrackedDomainEventMessage<T> |
GenericTrackedDomainEventMessage.withTrackingToken(TrackingToken trackingToken) |
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) |
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)
Reset tokens to the position as return by the given
initialTrackingTokenSupplier . |
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 . |
Constructor and Description |
---|
MultiSourceTrackingToken(Map<String,TrackingToken> trackingTokens)
Construct a new
MultiSourceTrackingToken from a map of existing tokens. |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
TokenStore.fetchToken(String processorName,
int segment)
|
TrackingToken |
AbstractTokenEntry.getToken(Serializer serializer)
Returns the token, deserializing it with given
serializer |
Modifier and Type | Method and Description |
---|---|
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. |
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 . |
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 . |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
InMemoryTokenStore.fetchToken(String processorName,
int segment) |
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) |
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 . |
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 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. |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
JpaTokenStore.fetchToken(String processorName,
int segment) |
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) |
Constructor and Description |
---|
TokenEntry(String processorName,
int segment,
TrackingToken token,
Serializer serializer)
Initializes a new token entry for given
token , processorName and segment . |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
FilteringEventStorageEngine.createHeadToken() |
TrackingToken |
FilteringEventStorageEngine.createTailToken() |
TrackingToken |
FilteringEventStorageEngine.createTokenAt(Instant dateTime) |
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) |
Modifier and Type | Method and Description |
---|---|
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.createHeadToken() |
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.createTailToken() |
default TrackingToken |
EventStorageEngine.createTokenAt(Instant dateTime)
Creates a token that tracks all events after given
dateTime . |
TrackingToken |
AbstractEventStore.createTokenAt(Instant dateTime) |
TrackingToken |
SequenceEventStorageEngine.createTokenAt(Instant dateTime) |
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<?>> |
EventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock)
Open an event stream containing all events stored since given tracking token.
|
Stream<? extends TrackedEventMessage<?>> |
SequenceEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock) |
Stream<? extends TrackedEventMessage<?>> |
AbstractEventStorageEngine.readEvents(TrackingToken trackingToken,
boolean mayBlock) |
Modifier and Type | Method and Description |
---|---|
TrackingToken |
InMemoryEventStorageEngine.createHeadToken() |
TrackingToken |
InMemoryEventStorageEngine.createTailToken() |
TrackingToken |
InMemoryEventStorageEngine.createTokenAt(Instant dateTime) |
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.
|
Modifier and Type | Method and Description |
---|---|
TrackingToken |
JdbcEventStorageEngine.createHeadToken() |
TrackingToken |
JdbcEventStorageEngine.createTailToken() |
TrackingToken |
JdbcEventStorageEngine.createTokenAt(Instant dateTime) |
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.
|
Modifier and Type | Method and Description |
---|---|
TrackingToken |
JpaEventStorageEngine.createHeadToken() |
TrackingToken |
JpaEventStorageEngine.createTailToken() |
TrackingToken |
JpaEventStorageEngine.createTokenAt(Instant dateTime) |
Modifier and Type | Method and Description |
---|---|
protected List<? extends TrackedEventData<?>> |
JpaEventStorageEngine.fetchTrackedEvents(TrackingToken lastToken,
int batchSize) |
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 . |
Modifier and Type | Method and Description |
---|---|
BlockingStream<M> |
StreamableMessageSource.openStream(TrackingToken trackingToken)
Open a stream containing all messages since given tracking token.
|
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() |
Copyright © 2010–2020. All rights reserved.