Uses of Interface
io.fluxzero.sdk.Fluxzero
Packages that use Fluxzero
Package
Description
-
Uses of Fluxzero in io.fluxzero.sdk
Fields in io.fluxzero.sdk with type parameters of type FluxzeroModifier and TypeFieldDescriptionstatic final AtomicReference<Fluxzero> Fluxzero.applicationInstanceFluxzero instance set by the current application.static final ThreadLocal<Fluxzero> Fluxzero.instanceThread-local binding of the currentFluxzeroinstance.Methods in io.fluxzero.sdk that return FluxzeroModifier and TypeMethodDescriptionstatic FluxzeroFluxzero.get()Returns the Fluxzero instance bound to the current thread or else set by the current application.Methods in io.fluxzero.sdk that return types with arguments of type FluxzeroModifier and TypeMethodDescriptionFluxzero.getOptionally()Returns the Fluxzero client bound to the current thread or else set by the current application as Optional.Method parameters in io.fluxzero.sdk with type arguments of type FluxzeroModifier and TypeMethodDescriptiondefault <R> RFluxzero.apply(ThrowingFunction<Fluxzero, R> function) Applies the given function with this Fluxzero set as current threadlocal instance.default voidFluxzero.execute(ThrowingConsumer<Fluxzero> task) Executes the given task with this Fluxzero set as current threadlocal instance. -
Uses of Fluxzero in io.fluxzero.sdk.configuration
Classes in io.fluxzero.sdk.configuration that implement FluxzeroMethods in io.fluxzero.sdk.configuration that return FluxzeroModifier and TypeMethodDescriptionBuilds the Fluxzero instance using the provided low-levelClient.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 Fluxzero in io.fluxzero.sdk.configuration.spring
Methods in io.fluxzero.sdk.configuration.spring that return FluxzeroModifier and TypeMethodDescriptionFluxzeroSpringConfig.fluxzero(FluxzeroBuilder builder, List<FluxzeroCustomizer> customizers) Constructs theFluxzeroinstance if no Fluxzero bean exists, preferring a user-providedClientor falling back to either aWebSocketClientorLocalClientdepending on presence of configuration properties.Methods in io.fluxzero.sdk.configuration.spring with parameters of type FluxzeroModifier and TypeMethodDescriptionFluxzeroSpringConfig.aggregateRepository(Fluxzero fluxzero) FluxzeroSpringConfig.commandGateway(Fluxzero fluxzero) FluxzeroSpringConfig.documentStore(Fluxzero fluxzero) FluxzeroSpringConfig.errorGateway(Fluxzero fluxzero) FluxzeroSpringConfig.eventGateway(Fluxzero fluxzero) FluxzeroSpringConfig.keyValueStore(Fluxzero fluxzero) FluxzeroSpringConfig.metricsGateway(Fluxzero fluxzero) FluxzeroSpringConfig.queryGateway(Fluxzero fluxzero) FluxzeroSpringConfig.resultGateway(Fluxzero fluxzero) -
Uses of Fluxzero in io.fluxzero.sdk.tracking
Methods in io.fluxzero.sdk.tracking with parameters of type FluxzeroModifier and TypeMethodDescriptionStarts tracking by assigning the given handlers to configured consumers and creating topic-specific or shared trackers.default RegistrationStarts the tracking process using the specified Fluxzero instance and the provided handlers.Starts tracking messages using the provided Fluxzero and a list of handlers.protected RegistrationDefaultTracking.startTracking(ConsumerConfiguration configuration, List<Handler<DeserializingMessage>> handlers, Fluxzero fluxzero) -
Uses of Fluxzero in io.fluxzero.sdk.tracking.client
Methods in io.fluxzero.sdk.tracking.client with parameters of type FluxzeroModifier and TypeMethodDescriptionstatic RegistrationDefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Fluxzero fluxzero) Starts one or more trackers.static RegistrationDefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, Fluxzero fluxzero) Starts one or more trackers. -
Uses of Fluxzero in io.fluxzero.sdk.web
Methods in io.fluxzero.sdk.web with parameters of type Fluxzero