Uses of Class
io.fluxzero.testserver.websocket.CommandIdempotencyStore
Packages that use CommandIdempotencyStore
-
Uses of CommandIdempotencyStore in io.fluxzero.testserver.websocket
Constructors in io.fluxzero.testserver.websocket with parameters of type CommandIdempotencyStoreModifierConstructorDescriptionConsumerEndpoint(MessageLogMaintenance maintenance, MessageType messageType, CommandIdempotencyStore commandIdempotencyStore) Creates a consumer endpoint backed by shared maintenance components for one message log.ConsumerEndpoint(MessageLogMaintenance maintenance, MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore) Creates a consumer endpoint backed by shared maintenance components for one message log.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, String topic, CommandIdempotencyStore commandIdempotencyStore) Creates a consumer endpoint from explicit tracking components.EventSourcingEndpoint(EventStoreClient eventStore, CommandIdempotencyStore commandIdempotencyStore) KeyValueEndPoint(KeyValueClient keyValueStore, CommandIdempotencyStore commandIdempotencyStore) ProducerEndpoint(MessageLogMaintenance maintenance, MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore) Creates a producer endpoint backed by the shared maintenance components for one message log.ProducerEndpoint(MessageStore store, MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore) SchedulingEndpoint(SchedulingClient store, CommandIdempotencyStore commandIdempotencyStore) SearchEndpoint(SearchClient store, CommandIdempotencyStore commandIdempotencyStore) protectedWebsocketEndpoint(CommandIdempotencyStore commandIdempotencyStore) protectedWebsocketEndpoint(Executor requestExecutor, CommandIdempotencyStore commandIdempotencyStore)