Uses of Interface
io.fluxcapacitor.common.tracking.MessageStore
Packages that use MessageStore
Package
Description
-
Uses of MessageStore in io.fluxcapacitor.common.tracking
Methods in io.fluxcapacitor.common.tracking with type parameters of type MessageStoreModifier and TypeMethodDescriptiondefault <T extends MessageStore>
TAttempts to unwrap the current instance to a concrete implementation or extension ofMessageStore
.Methods in io.fluxcapacitor.common.tracking that return MessageStoreModifier and TypeMethodDescriptionHasMessageStore.getMessageStore()
Returns the associatedMessageStore
instance.default MessageStore
MessageStore.getMessageStore()
Returns the current instance as theMessageStore
.Constructors in io.fluxcapacitor.common.tracking with parameters of type MessageStoreModifierConstructorDescriptionDefaultTrackingStrategy
(MessageStore source) DefaultTrackingStrategy
(MessageStore source, TaskScheduler scheduler) protected
DefaultTrackingStrategy
(MessageStore source, TaskScheduler scheduler, int segments) -
Uses of MessageStore in io.fluxcapacitor.javaclient.persisting.eventsourcing.client
Classes in io.fluxcapacitor.javaclient.persisting.eventsourcing.client that implement MessageStoreModifier and TypeClassDescriptionclass
An implementation of theEventStoreClient
interface that provides an in-memory event storage solution. -
Uses of MessageStore in io.fluxcapacitor.javaclient.persisting.search.client
Classes in io.fluxcapacitor.javaclient.persisting.search.client that implement MessageStoreModifier and TypeClassDescriptionclass
AMessageStore
implementation backed by a collection in anInMemorySearchStore
. -
Uses of MessageStore in io.fluxcapacitor.javaclient.scheduling.client
Classes in io.fluxcapacitor.javaclient.scheduling.client that implement MessageStoreModifier and TypeClassDescriptionclass
An in-memory implementation of a scheduling store that allows the scheduling, retrieval, and management of scheduled messages. -
Uses of MessageStore in io.fluxcapacitor.javaclient.tracking.client
Classes in io.fluxcapacitor.javaclient.tracking.client that implement MessageStoreModifier and TypeClassDescriptionclass
An in-memory implementation of theMessageStore
interface for storingSerializedMessage
s without external persistence.Constructors in io.fluxcapacitor.javaclient.tracking.client with parameters of type MessageStoreModifierConstructorDescriptionLocalTrackingClient
(MessageStore messageStore, MessageType messageType) LocalTrackingClient
(MessageStore messageStore, MessageType messageType, String topic) -
Uses of MessageStore in io.fluxcapacitor.testserver.metrics
Constructors in io.fluxcapacitor.testserver.metrics with parameters of type MessageStoreModifierConstructorDescriptionDefaultMetricsLog
(MessageStore store) DefaultMetricsLog
(MessageStore store, ExecutorService workerPool) -
Uses of MessageStore in io.fluxcapacitor.testserver.scheduling
Classes in io.fluxcapacitor.testserver.scheduling that implement MessageStore -
Uses of MessageStore in io.fluxcapacitor.testserver.websocket
Constructors in io.fluxcapacitor.testserver.websocket with parameters of type MessageStoreModifierConstructorDescriptionConsumerEndpoint
(MessageStore messageStore, MessageType messageType)