Uses of Interface
io.fluxzero.sdk.Fluxzero

Packages that use Fluxzero

Package	Description
io.fluxzero.sdk
io.fluxzero.sdk.configuration
io.fluxzero.sdk.configuration.spring
io.fluxzero.sdk.tracking
io.fluxzero.sdk.tracking.client
io.fluxzero.sdk.web

Uses of Fluxzero in io.fluxzero.sdk

Fields in io.fluxzero.sdk with type parameters of type Fluxzero

Modifier and Type	Field	Description
static final AtomicReference<Fluxzero>	Fluxzero.applicationInstance	Fluxzero instance set by the current application.
static final ThreadLocal<Fluxzero>	Fluxzero.instance	Thread-local binding of the current Fluxzero instance.

Methods in io.fluxzero.sdk that return Fluxzero

Modifier and Type	Method	Description
static Fluxzero	Fluxzero.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 Fluxzero

Modifier and Type	Method	Description
static Optional<Fluxzero>	Fluxzero.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 Fluxzero

Modifier and Type	Method	Description
default <R> R	Fluxzero.apply(ThrowingFunction<Fluxzero,R> function)	Applies the given function with this Fluxzero set as current threadlocal instance.
default void	Fluxzero.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 Fluxzero

Modifier and Type	Class	Description
class	DefaultFluxzero

Methods in io.fluxzero.sdk.configuration that return Fluxzero

Modifier and Type	Method	Description
Fluxzero	DefaultFluxzero.Builder.build(@NonNull Client client)
Fluxzero	FluxzeroBuilder.build(Client client)	Builds the Fluxzero instance using the provided low-level Client.
protected Fluxzero	DefaultFluxzero.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 Fluxzero

Modifier and Type	Method	Description
Fluxzero	FluxzeroSpringConfig.fluxzero(FluxzeroBuilder builder, List<FluxzeroCustomizer> customizers)	Constructs the Fluxzero instance if no Fluxzero bean exists, preferring a user-provided Client or falling back to either a WebSocketClient or LocalClient depending on presence of configuration properties.

Methods in io.fluxzero.sdk.configuration.spring with parameters of type Fluxzero

Modifier and Type	Method	Description
AggregateRepository	FluxzeroSpringConfig.aggregateRepository(Fluxzero fluxzero)
CommandGateway	FluxzeroSpringConfig.commandGateway(Fluxzero fluxzero)
DocumentStore	FluxzeroSpringConfig.documentStore(Fluxzero fluxzero)
ErrorGateway	FluxzeroSpringConfig.errorGateway(Fluxzero fluxzero)
EventGateway	FluxzeroSpringConfig.eventGateway(Fluxzero fluxzero)
KeyValueStore	FluxzeroSpringConfig.keyValueStore(Fluxzero fluxzero)
MetricsGateway	FluxzeroSpringConfig.metricsGateway(Fluxzero fluxzero)
QueryGateway	FluxzeroSpringConfig.queryGateway(Fluxzero fluxzero)
ResultGateway	FluxzeroSpringConfig.resultGateway(Fluxzero fluxzero)
MessageScheduler	FluxzeroSpringConfig.scheduler(Fluxzero fluxzero)

Uses of Fluxzero in io.fluxzero.sdk.tracking

Methods in io.fluxzero.sdk.tracking with parameters of type Fluxzero

Modifier and Type	Method	Description
Registration	DefaultTracking.start(Fluxzero fluxzero, List<?> handlers)	Starts tracking by assigning the given handlers to configured consumers and creating topic-specific or shared trackers.
default Registration	Tracking.start(Fluxzero fluxzero, Object... handlers)	Starts the tracking process using the specified Fluxzero instance and the provided handlers.
Registration	Tracking.start(Fluxzero fluxzero, List<?> handlers)	Starts tracking messages using the provided Fluxzero and a list of handlers.
protected Registration	DefaultTracking.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 Fluxzero

Modifier and Type	Method	Description
static Registration	DefaultTracker.start(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, Fluxzero fluxzero)	Starts one or more trackers.
static Registration	DefaultTracker.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

Modifier and Type	Method	Description
void	ForwardingWebConsumer.start(Fluxzero fluxzero)