org.axonframework.eventhandling

Interface EventTrackerStatus

public interface EventTrackerStatus

Interface describing the status of a Segment of a TrackingProcessor.

Method Summary

Modifier and Type	Method and Description
Segment	getSegment() The segment for which this status is valid.
TrackingToken	getTrackingToken() The tracking token of the last event that has been seen by this Segment.
boolean	isCaughtUp() Whether the Segment of this status has caught up with the head of the event stream.
boolean	isReplaying() Indicates whether this Segment is still replaying previously processed Events.

Method Detail

getSegment

Segment getSegment()

The segment for which this status is valid.

Returns:

segment for which this status is valid

isCaughtUp

boolean isCaughtUp()

Whether the Segment of this status has caught up with the head of the event stream. Note that this is no guarantee that this segment is still processing at (or near) real-time events. It merely indicates that this segment has been at the head of the stream since it started processing. It may have fallen back since then.

Returns:

whether the Segment of this status has caught up with the head of the event stream

isReplaying

boolean isReplaying()

Indicates whether this Segment is still replaying previously processed Events.

Note that this method will only recognize a replay if the tokens have been reset using TrackingEventProcessor.resetTokens(). Removing tokens directly from the underlying TokenStore will not be recognized as a replay.

Returns:

true if this segment is replaying historic events after a reset, otherwise false

getTrackingToken

TrackingToken getTrackingToken()

The tracking token of the last event that has been seen by this Segment.

The returned tracking token represents the position of this segment in the event stream. In case of a recent merge of segments, the token represents the lowest position of the two merged segments.

Returns:

tracking token of the last event that has been seen by this Segment