Uses of Interface
io.fluxzero.javaclient.Fluxzero

Packages that use Fluxzero

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

Uses of Fluxzero in io.fluxzero.javaclient

Fields in io.fluxzero.javaclient 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.javaclient 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.javaclient 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.javaclient with type arguments of type Fluxzero

Modifier and Type	Method	Description
default <R> R	Fluxzero.apply(io.fluxzero.common.ThrowingFunction<Fluxzero,R> function)	Applies the given function with this Fluxzero set as current threadlocal instance.
default void	Fluxzero.execute(io.fluxzero.common.ThrowingConsumer<Fluxzero> task)	Executes the given task with this Fluxzero set as current threadlocal instance.

Uses of Fluxzero in io.fluxzero.javaclient.configuration

Classes in io.fluxzero.javaclient.configuration that implement Fluxzero

Modifier and Type	Class	Description
class	DefaultFluxzero

Methods in io.fluxzero.javaclient.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<io.fluxzero.common.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, io.fluxzero.common.application.PropertySource propertySource, io.fluxzero.common.DelegatingClock clock, io.fluxzero.common.TaskScheduler taskScheduler, Client client, io.fluxzero.common.ThrowingRunnable shutdownHandler)

Uses of Fluxzero in io.fluxzero.javaclient.configuration.spring

Methods in io.fluxzero.javaclient.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.javaclient.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.javaclient.tracking

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

Modifier and Type	Method	Description
io.fluxzero.common.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 io.fluxzero.common.Registration	Tracking.start(Fluxzero fluxzero, Object... handlers)	Starts the tracking process using the specified Fluxzero instance and the provided handlers.
io.fluxzero.common.Registration	Tracking.start(Fluxzero fluxzero, List<?> handlers)	Starts tracking messages using the provided Fluxzero and a list of handlers.
protected io.fluxzero.common.Registration	DefaultTracking.startTracking(ConsumerConfiguration configuration, List<io.fluxzero.common.handling.Handler<DeserializingMessage>> handlers, Fluxzero fluxzero)

Uses of Fluxzero in io.fluxzero.javaclient.tracking.client

Methods in io.fluxzero.javaclient.tracking.client with parameters of type Fluxzero

Modifier and Type	Method	Description
static io.fluxzero.common.Registration	DefaultTracker.start(Consumer<List<io.fluxzero.common.api.SerializedMessage>> consumer, io.fluxzero.common.MessageType messageType, ConsumerConfiguration config, Fluxzero fluxzero)	Starts one or more trackers.
static io.fluxzero.common.Registration	DefaultTracker.start(Consumer<List<io.fluxzero.common.api.SerializedMessage>> consumer, io.fluxzero.common.MessageType messageType, String topic, ConsumerConfiguration config, Fluxzero fluxzero)	Starts one or more trackers.

Uses of Fluxzero in io.fluxzero.javaclient.web

Methods in io.fluxzero.javaclient.web with parameters of type Fluxzero

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