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(io.fluxzero.common.tracking.MessageLogMaintenance maintenance, io.fluxzero.common.MessageType messageType, CommandIdempotencyStore commandIdempotencyStore) Creates a consumer endpoint backed by shared maintenance components for one message log.ConsumerEndpoint(io.fluxzero.common.tracking.MessageLogMaintenance maintenance, io.fluxzero.common.MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore) Creates a consumer endpoint backed by shared maintenance components for one message log.ConsumerEndpoint(io.fluxzero.common.tracking.MessageStore messageStore, io.fluxzero.common.MessageType messageType, CommandIdempotencyStore commandIdempotencyStore) ConsumerEndpoint(io.fluxzero.common.tracking.MessageStore messageStore, io.fluxzero.common.MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore) Creates a consumer endpoint for a topic-specific message log.ConsumerEndpoint(io.fluxzero.common.tracking.TrackingStrategy trackingStrategy, io.fluxzero.common.tracking.MessageStore messageStore, io.fluxzero.common.tracking.PositionStore positionStore, io.fluxzero.common.MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore) Creates a consumer endpoint from explicit tracking components.EventSourcingEndpoint(io.fluxzero.sdk.persisting.eventsourcing.client.EventStoreClient eventStore, CommandIdempotencyStore commandIdempotencyStore) KeyValueEndPoint(io.fluxzero.sdk.persisting.keyvalue.client.KeyValueClient keyValueStore, CommandIdempotencyStore commandIdempotencyStore) ProducerEndpoint(io.fluxzero.common.tracking.MessageLogMaintenance maintenance, io.fluxzero.common.MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore) Creates a producer endpoint backed by the shared maintenance components for one message log.ProducerEndpoint(io.fluxzero.common.tracking.MessageStore store, io.fluxzero.common.MessageType messageType, String topic, CommandIdempotencyStore commandIdempotencyStore) SchedulingEndpoint(io.fluxzero.sdk.scheduling.client.SchedulingClient store, CommandIdempotencyStore commandIdempotencyStore) SearchEndpoint(io.fluxzero.sdk.persisting.search.client.SearchClient store, CommandIdempotencyStore commandIdempotencyStore) protectedWebsocketEndpoint(CommandIdempotencyStore commandIdempotencyStore) protectedWebsocketEndpoint(Executor requestExecutor, CommandIdempotencyStore commandIdempotencyStore)