Uses of Interface
io.fluxzero.common.tracking.PositionStore
Packages that use PositionStore
-
Uses of PositionStore in io.fluxzero.common.tracking
Classes in io.fluxzero.common.tracking that implement PositionStoreMethods in io.fluxzero.common.tracking with parameters of type PositionStoreModifier and TypeMethodDescriptionvoidDefaultTrackingStrategy.claimSegment(Tracker tracker, PositionStore positionStore) voidTrackingStrategy.claimSegment(Tracker tracker, PositionStore positionStore) Claims one or more message segments for the given tracker.voidDefaultTrackingStrategy.getBatch(Tracker tracker, PositionStore positionStore) voidTrackingStrategy.getBatch(Tracker tracker, PositionStore positionStore) Requests a new batch of messages for the given tracker.protected PositionDefaultTrackingStrategy.position(Tracker tracker, PositionStore positionStore, int[] segment) protected voidDefaultTrackingStrategy.waitForMessages(Tracker tracker, MessageBatch emptyBatch, PositionStore positionStore)