Uses of Interface
io.fluxcapacitor.javaclient.FluxCapacitor
Packages that use FluxCapacitor
Package
Description
-
Uses of FluxCapacitor in io.fluxcapacitor.javaclient
Fields in io.fluxcapacitor.javaclient with type parameters of type FluxCapacitorModifier and TypeFieldDescriptionstatic final AtomicReference
<FluxCapacitor> FluxCapacitor.applicationInstance
Flux Capacitor instance set by the current application.static final ThreadLocal
<FluxCapacitor> FluxCapacitor.instance
Thread-local binding of the currentFluxCapacitor
instance.Methods in io.fluxcapacitor.javaclient that return FluxCapacitorModifier and TypeMethodDescriptionstatic FluxCapacitor
FluxCapacitor.get()
Returns the Flux Capacitor instance bound to the current thread or else set by the current application.Methods in io.fluxcapacitor.javaclient that return types with arguments of type FluxCapacitorModifier and TypeMethodDescriptionstatic Optional
<FluxCapacitor> FluxCapacitor.getOptionally()
Returns the FluxCapacitor client bound to the current thread or else set by the current application as Optional.Method parameters in io.fluxcapacitor.javaclient with type arguments of type FluxCapacitorModifier and TypeMethodDescriptiondefault <R> R
FluxCapacitor.apply
(ThrowingFunction<FluxCapacitor, R> function) Applies the given function with this Flux Capacitor set as current threadlocal instance.default void
FluxCapacitor.execute
(ThrowingConsumer<FluxCapacitor> task) Executes the given task with this Flux Capacitor set as current threadlocal instance. -
Uses of FluxCapacitor in io.fluxcapacitor.javaclient.configuration
Classes in io.fluxcapacitor.javaclient.configuration that implement FluxCapacitorMethods in io.fluxcapacitor.javaclient.configuration that return FluxCapacitorModifier and TypeMethodDescriptionBuilds the FluxCapacitor instance using the provided low-levelClient
.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 FluxCapacitor in io.fluxcapacitor.javaclient.configuration.spring
Methods in io.fluxcapacitor.javaclient.configuration.spring that return FluxCapacitorModifier and TypeMethodDescriptionFluxCapacitorSpringConfig.fluxCapacitor
(FluxCapacitorBuilder builder, List<FluxCapacitorCustomizer> customizers) Constructs theFluxCapacitor
instance if no FluxCapacitor bean exists, preferring a user-providedClient
or falling back to either aWebSocketClient
orLocalClient
depending on presence of configuration properties.Methods in io.fluxcapacitor.javaclient.configuration.spring with parameters of type FluxCapacitorModifier and TypeMethodDescriptionFluxCapacitorSpringConfig.aggregateRepository
(FluxCapacitor fluxCapacitor) FluxCapacitorSpringConfig.commandGateway
(FluxCapacitor fluxCapacitor) FluxCapacitorSpringConfig.documentStore
(FluxCapacitor fluxCapacitor) FluxCapacitorSpringConfig.errorGateway
(FluxCapacitor fluxCapacitor) FluxCapacitorSpringConfig.eventGateway
(FluxCapacitor fluxCapacitor) FluxCapacitorSpringConfig.keyValueStore
(FluxCapacitor fluxCapacitor) FluxCapacitorSpringConfig.metricsGateway
(FluxCapacitor fluxCapacitor) FluxCapacitorSpringConfig.queryGateway
(FluxCapacitor fluxCapacitor) FluxCapacitorSpringConfig.resultGateway
(FluxCapacitor fluxCapacitor) FluxCapacitorSpringConfig.scheduler
(FluxCapacitor fluxCapacitor) -
Uses of FluxCapacitor in io.fluxcapacitor.javaclient.tracking
Methods in io.fluxcapacitor.javaclient.tracking with parameters of type FluxCapacitorModifier and TypeMethodDescriptionDefaultTracking.start
(FluxCapacitor fluxCapacitor, List<?> handlers) Starts tracking by assigning the given handlers to configured consumers and creating topic-specific or shared trackers.default Registration
Tracking.start
(FluxCapacitor fluxCapacitor, Object... handlers) Starts the tracking process using the specified FluxCapacitor instance and the provided handlers.Tracking.start
(FluxCapacitor fluxCapacitor, List<?> handlers) Starts tracking messages using the provided FluxCapacitor and a list of handlers.protected Registration
DefaultTracking.startTracking
(ConsumerConfiguration configuration, List<Handler<DeserializingMessage>> handlers, FluxCapacitor fluxCapacitor) -
Uses of FluxCapacitor in io.fluxcapacitor.javaclient.tracking.client
Methods in io.fluxcapacitor.javaclient.tracking.client with parameters of type FluxCapacitorModifier and TypeMethodDescriptionstatic Registration
DefaultTracker.start
(Consumer<List<SerializedMessage>> consumer, MessageType messageType, ConsumerConfiguration config, FluxCapacitor fluxCapacitor) Starts one or more trackers.static Registration
DefaultTracker.start
(Consumer<List<SerializedMessage>> consumer, MessageType messageType, String topic, ConsumerConfiguration config, FluxCapacitor fluxCapacitor) Starts one or more trackers. -
Uses of FluxCapacitor in io.fluxcapacitor.javaclient.web
Methods in io.fluxcapacitor.javaclient.web with parameters of type FluxCapacitor