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

Packages that use MessageStore

Package	Description
io.fluxzero.common.tracking
io.fluxzero.sdk.persisting.eventsourcing.client
io.fluxzero.sdk.persisting.search.client
io.fluxzero.sdk.scheduling.client
io.fluxzero.sdk.tracking.client
io.fluxzero.testserver.metrics
io.fluxzero.testserver.scheduling
io.fluxzero.testserver.websocket

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)
	MessageLogMaintenance(MessageStore messageStore, PositionStore positionStore, TrackingStrategy trackingStrategy)	Creates message log maintenance for the given shared log components.

Uses of MessageStore in io.fluxzero.sdk.persisting.eventsourcing.client

Classes in io.fluxzero.sdk.persisting.eventsourcing.client that implement MessageStore

Modifier and Type	Class	Description
class	InMemoryEventStore	An implementation of the EventStoreClient interface that provides an in-memory event storage solution.

Uses of MessageStore in io.fluxzero.sdk.persisting.search.client

Classes in io.fluxzero.sdk.persisting.search.client that implement MessageStore

Modifier and Type	Class	Description
class	CollectionMessageStore	A MessageStore implementation backed by a collection in an InMemorySearchStore.

Uses of MessageStore in io.fluxzero.sdk.scheduling.client

Classes in io.fluxzero.sdk.scheduling.client that implement MessageStore

Modifier and Type	Class	Description
class	InMemoryScheduleStore	An in-memory implementation of a scheduling store that allows the scheduling, retrieval, and management of scheduled messages.

Uses of MessageStore in io.fluxzero.sdk.tracking.client

Classes in io.fluxzero.sdk.tracking.client that implement MessageStore

Modifier and Type	Class	Description
class	InMemoryMessageStore	An in-memory implementation of the MessageStore interface for storing SerializedMessages without external persistence.

Constructors in io.fluxzero.sdk.tracking.client with parameters of type MessageStore

Modifier	Constructor	Description
	LocalTrackingClient(MessageStore messageStore, MessageType messageType)
	LocalTrackingClient(MessageStore messageStore, MessageType messageType, String topic)

Uses of MessageStore in io.fluxzero.testserver.metrics

Constructors in io.fluxzero.testserver.metrics with parameters of type MessageStore

Modifier	Constructor	Description
	DefaultMetricsLog(MessageStore store)
	DefaultMetricsLog(MessageStore store, ExecutorService workerPool)

Uses of MessageStore in io.fluxzero.testserver.scheduling

Classes in io.fluxzero.testserver.scheduling that implement MessageStore

Modifier and Type	Class	Description
class	TestServerScheduleStore

Uses of MessageStore in io.fluxzero.testserver.websocket

Constructors in io.fluxzero.testserver.websocket with parameters of type MessageStore

Modifier	Constructor	Description
	ConsumerEndpoint(MessageStore messageStore, MessageType messageType)
	ConsumerEndpoint(MessageStore messageStore, MessageType messageType, CommandIdempotencyStore commandIdempotencyStore)
	ConsumerEndpoint(MessageStore messageStore, MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore)	Creates a consumer endpoint for a topic-specific message log.
	ConsumerEndpoint(TrackingStrategy trackingStrategy, MessageStore messageStore, PositionStore positionStore, MessageType messageType)
	ConsumerEndpoint(TrackingStrategy trackingStrategy, MessageStore messageStore, PositionStore positionStore, MessageType messageType, String topic)	Creates a consumer endpoint from explicit tracking components.
	ConsumerEndpoint(TrackingStrategy trackingStrategy, MessageStore messageStore, PositionStore positionStore, MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore)	Creates a consumer endpoint from explicit tracking components.
	ProducerEndpoint(MessageStore store)
	ProducerEndpoint(MessageStore store, MessageType messageType, String topic)
	ProducerEndpoint(MessageStore store, MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore)