Package io.fluxcapacitor.common.tracking
package io.fluxcapacitor.common.tracking
-
ClassDescriptionStreaming strategy that allows multiple clients to concurrently consume a message stream.Interface for components that expose a
MessageStore
.A low-level store for serialized messages.Interface for storing and retrievingPosition
objects representing the last processed message indexes per segment for a given consumer.ATracker
represents an active consumer of messages for a particularConsumerConfiguration
.Represents the current set ofTracker
s that are connected for a specific consumer.ATrackingStrategy
defines how aTracker
consumes messages from a message log or distributed segment space.