Uses of Interface
io.fluxzero.sdk.configuration.client.Client
Packages that use Client
Package
Description
-
Uses of Client in io.fluxzero.proxy
Methods in io.fluxzero.proxy with parameters of type ClientConstructors in io.fluxzero.proxy with parameters of type ClientModifierConstructorDescriptionProxyRequestHandler(Client client) WebsocketEndpoint(Client client) -
Uses of Client in io.fluxzero.sdk
Methods in io.fluxzero.sdk that return Client -
Uses of Client in io.fluxzero.sdk.configuration
Methods in io.fluxzero.sdk.configuration with parameters of type ClientModifier and TypeMethodDescriptionBuilds the Fluxzero instance using the provided low-levelClient.protected GenericGatewayDefaultFluxzero.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 FluxzeroDefaultFluxzero.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.fluxzero.sdk.configuration.client
Classes in io.fluxzero.sdk.configuration.client that implement ClientModifier and TypeClassDescriptionclassAbstract base implementation of theClientinterface, providing shared logic and lifecycle management for both local (in-memory) and remote (WebSocket-based) Fluxzero clients.classAn in-memoryClientimplementation used for local development, testing, or isolated environments where no connection to the Fluxzero Runtime is required.classAClientimplementation that connects to the Fluxzero Runtime using WebSocket connections.Subinterfaces with type arguments of type Client in io.fluxzero.sdk.configuration.clientModifier and TypeInterfaceDescriptioninterfaceDefines the low-level client contract used byFluxzeroBuilderto construct aFluxzeroinstance.Methods in io.fluxzero.sdk.configuration.client that return ClientModifier and TypeMethodDescriptionLocalClient.forNamespace(String namespace) WebSocketClient.forNamespace(String namespace) default ClientClient.unwrap()Returns the underlyingClientimplementation. -
Uses of Client in io.fluxzero.sdk.publishing
Constructors in io.fluxzero.sdk.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.fluxzero.sdk.publishing.correlation
Methods in io.fluxzero.sdk.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.fluxzero.sdk.tracking.client
Methods in io.fluxzero.sdk.tracking.client with parameters of type ClientModifier and TypeMethodDescriptionstatic RegistrationDefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Client client) Starts one or more trackers.static RegistrationDefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, Client client) Starts one or more trackers.