Package io.fluxzero.common.tracking
package io.fluxzero.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 retrievingPositionobjects representing the last processed message indexes per segment for a given consumer.ATrackerrepresents an active consumer of messages for a particularConsumerConfiguration.Represents the current set ofTrackers that are connected for a specific consumer.ATrackingStrategydefines how aTrackerconsumes messages from a message log or distributed segment space.