Uses of Interface
io.fluxzero.common.tracking.MessageStore

Packages that use MessageStore

Package	Description
io.fluxzero.common.tracking

Uses of MessageStore in io.fluxzero.common.tracking

Methods in io.fluxzero.common.tracking with type parameters of type MessageStore

Modifier and Type	Method	Description
default <T extends MessageStore> T	MessageStore.unwrap(Class<T> type)	Attempts to unwrap the current instance to a concrete implementation or extension of MessageStore.

Methods in io.fluxzero.common.tracking that return MessageStore

Modifier and Type	Method	Description
MessageStore	HasMessageStore.getMessageStore()	Returns the associated MessageStore instance.
MessageStore	MessageLogMaintenance.getMessageStore()	Returns the message store maintained by this instance.
default MessageStore	MessageStore.getMessageStore()	Returns the current instance as the MessageStore.

Constructors in io.fluxzero.common.tracking with parameters of type MessageStore

Modifier	Constructor	Description
	DefaultTrackingStrategy(MessageStore source, PositionStore positionStore)
	DefaultTrackingStrategy(MessageStore source, PositionStore positionStore, TaskScheduler scheduler)
protected	DefaultTrackingStrategy(MessageStore source, PositionStore positionStore, TaskScheduler scheduler, int segments)
protected	DefaultTrackingStrategy(MessageStore source, PositionStore positionStore, TaskScheduler scheduler, int segments, Duration initialPositionLag)
protected	DefaultTrackingStrategy(MessageStore source, PositionStore positionStore, TaskScheduler scheduler, Duration initialPositionLag)
	DefaultTrackingStrategy(MessageStore source, PositionStore positionStore, Duration initialPositionLag)	Creates a tracking strategy with a configurable look-back for consumers without a stored position.
	MessageLogMaintenance(MessageStore messageStore, PositionStore positionStore, TrackingStrategy trackingStrategy)	Creates message log maintenance for the given shared log components.