Uses of Interface
io.fluxcapacitor.javaclient.configuration.client.Client
Packages that use Client
Package
Description
-
Uses of Client in io.fluxcapacitor.javaclient
Methods in io.fluxcapacitor.javaclient that return Client -
Uses of Client in io.fluxcapacitor.javaclient.configuration
Methods in io.fluxcapacitor.javaclient.configuration with parameters of type ClientModifier and TypeMethodDescriptionBuilds the FluxCapacitor instance using the provided low-levelClient
.protected GenericGateway
DefaultFluxCapacitor.Builder.createRequestGateway
(Client client, MessageType messageType, String topic, RequestHandler requestHandler, Map<MessageType, DispatchInterceptor> dispatchInterceptors, Map<MessageType, HandlerDecorator> handlerDecorators, List<ParameterResolver<? super DeserializingMessage>> parameterResolvers, Function<Class<?>, HandlerRepository> handlerRepositorySupplier, RepositoryProvider repositoryProvider, ResponseMapper responseMapper) protected FluxCapacitor
DefaultFluxCapacitor.Builder.doBuild
(Map<MessageType, ? extends Tracking> trackingSupplier, Function<String, ? extends GenericGateway> customGatewaySupplier, CommandGateway commandGateway, QueryGateway queryGateway, EventGateway eventGateway, ResultGateway resultGateway, ErrorGateway errorGateway, MetricsGateway metricsGateway, WebRequestGateway webRequestGateway, AggregateRepository aggregateRepository, SnapshotStore snapshotStore, EventStore eventStore, KeyValueStore keyValueStore, DocumentStore documentStore, MessageScheduler messageScheduler, UserProvider userProvider, Cache cache, Serializer serializer, CorrelationDataProvider correlationDataProvider, IdentityProvider identityProvider, PropertySource propertySource, DelegatingClock clock, TaskScheduler taskScheduler, Client client, ThrowingRunnable shutdownHandler) -
Uses of Client in io.fluxcapacitor.javaclient.configuration.client
Classes in io.fluxcapacitor.javaclient.configuration.client that implement ClientModifier and TypeClassDescriptionclass
Abstract base implementation of theClient
interface, providing shared logic and lifecycle management for both local (in-memory) and remote (WebSocket-based) Flux clients.class
An in-memoryClient
implementation used for local development, testing, or isolated runtime environments where no connection to the Flux Platform is required.class
AClient
implementation that connects to the Flux Platform using WebSocket connections.Methods in io.fluxcapacitor.javaclient.configuration.client that return Client -
Uses of Client in io.fluxcapacitor.javaclient.publishing
Constructors in io.fluxcapacitor.javaclient.publishing with parameters of type ClientModifierConstructorDescriptionDefaultRequestHandler
(Client client, MessageType resultType) Constructs a DefaultRequestHandler with the specified client and message type, and a default timeout of 200 seconds. -
Uses of Client in io.fluxcapacitor.javaclient.publishing.correlation
Methods in io.fluxcapacitor.javaclient.publishing.correlation with parameters of type ClientModifier and TypeMethodDescriptionCorrelationDataProvider.getCorrelationData
(Client client, SerializedMessage currentMessage, MessageType messageType) Returns correlation metadata derived from a serialized message and optional context. -
Uses of Client in io.fluxcapacitor.javaclient.tracking.client
Methods in io.fluxcapacitor.javaclient.tracking.client with parameters of type ClientModifier and TypeMethodDescriptionstatic Registration
DefaultTracker.start
(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Client client) Starts one or more trackers.static Registration
DefaultTracker.start
(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, Client client) Starts one or more trackers. -
Uses of Client in io.fluxcapacitor.proxy
Methods in io.fluxcapacitor.proxy with parameters of type ClientConstructors in io.fluxcapacitor.proxy with parameters of type ClientModifierConstructorDescriptionProxyRequestHandler
(Client client) WebsocketEndpoint
(Client client)