Uses of Package
io.fluxcapacitor.common
Packages that use io.fluxcapacitor.common
Package
Description
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.commonClassDescriptionA thread-safe batching queue that asynchronously flushes its content to a consumer in configurable batch sizes.Functional interface for handling errors during tasks.Represents a delivery or completion guarantee for messages or state changes in Flux Capacitor.A
BiFunction
that memoizes (caches) its results based on a pair of input arguments.AFunction
that memoizes (caches) its results by key.ASupplier
that memoizes (caches) the result of a single computation.Enumerates the types of messages recognized and routed by the Flux platform.Represents a resource or component that can be monitored.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.Configuration for retry behavior when executing a task usingTimingUtils.retryOnFailure(java.lang.Runnable, java.time.Duration)
.Represents the current status of a retry operation.Interface for in-memory scheduling of tasks in a way that supports deterministic testing and virtualized time.BiConsumer
-like interface whoseThrowingBiConsumer.accept(Object, Object)
method may throw a checkedException
.Variant ofBiFunction
whoseThrowingBiFunction.apply(Object, Object)
method is allowed to throw a checkedException
.Functional counterpart toConsumer
that allows theThrowingConsumer.accept(Object)
method to throw a checkedException
.Runnable-like interface whoseThrowingRunnable.run()
method is allowed to throw a checkedException
. -
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.common.apiClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.common.api.keyvalueClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.common.api.publishingClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.common.api.trackingClassDescriptionEnumerates the types of messages recognized and routed by the Flux platform.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.common.handlingClassDescriptionRunnable-like interface whose
ThrowingRunnable.run()
method is allowed to throw a checkedException
. -
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.common.searchClassDescription
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.common.trackingClassDescriptionEnumerates the types of messages recognized and routed by the Flux platform.Represents a resource or component that can be monitored.Interface for in-memory scheduling of tasks in a way that supports deterministic testing and virtualized time.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclientClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.Enumerates the types of messages recognized and routed by the Flux platform.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.Interface for in-memory scheduling of tasks in a way that supports deterministic testing and virtualized time.Functional counterpart to
Consumer
that allows theThrowingConsumer.accept(Object)
method to throw a checkedException
. -
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.commonClassDescriptionA
BiFunction
that memoizes (caches) its results based on a pair of input arguments.AFunction
that memoizes (caches) its results by key.ASupplier
that memoizes (caches) the result of a single computation.Enumerates the types of messages recognized and routed by the Flux platform. -
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.common.serializationClassDescriptionA
Function
that memoizes (caches) its results by key.Enumerates the types of messages recognized and routed by the Flux platform.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.Functional counterpart toConsumer
that allows theThrowingConsumer.accept(Object)
method to throw a checkedException
. -
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.common.serialization.castingClassDescriptionRepresents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.common.serialization.jacksonClassDescriptionFunctional counterpart to
Consumer
that allows theThrowingConsumer.accept(Object)
method to throw a checkedException
. -
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.common.websocketClassDescriptionEnumerates the types of messages recognized and routed by the Flux platform.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.configurationClassDescriptionEnumerates the types of messages recognized and routed by the Flux platform.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.Interface for in-memory scheduling of tasks in a way that supports deterministic testing and virtualized time.Runnable-like interface whose
ThrowingRunnable.run()
method is allowed to throw a checkedException
. -
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.configuration.clientClassDescriptionEnumerates the types of messages recognized and routed by the Flux platform.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.configuration.springClassDescriptionRepresents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.persisting.cachingClassDescriptionRepresents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.persisting.keyvalueClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.persisting.keyvalue.clientClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.persisting.searchClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.persisting.search.clientClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.Represents a resource or component that can be monitored.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.publishingClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.Enumerates the types of messages recognized and routed by the Flux platform.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.publishing.clientClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.Enumerates the types of messages recognized and routed by the Flux platform.Represents a resource or component that can be monitored.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.publishing.correlationClassDescriptionEnumerates the types of messages recognized and routed by the Flux platform.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.publishing.dataprotectionClassDescriptionEnumerates the types of messages recognized and routed by the Flux platform.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.publishing.routingClassDescriptionEnumerates the types of messages recognized and routed by the Flux platform.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.schedulingClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.Enumerates the types of messages recognized and routed by the Flux platform.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.scheduling.client
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.trackingClassDescriptionRepresents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.tracking.clientClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.Enumerates the types of messages recognized and routed by the Flux platform.Represents a resource or component that can be monitored.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.tracking.handlingClassDescriptionEnumerates the types of messages recognized and routed by the Flux platform.Represents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.tracking.handling.authenticationClassDescriptionEnumerates the types of messages recognized and routed by the Flux platform.Runnable-like interface whose
ThrowingRunnable.run()
method is allowed to throw a checkedException
. -
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.javaclient.webClassDescriptionRepresents a delivery or completion guarantee for messages or state changes in Flux Capacitor.Enumerates the types of messages recognized and routed by the Flux platform.Interface for in-memory scheduling of tasks in a way that supports deterministic testing and virtualized time.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.proxyClassDescriptionRepresents a handle for a cancellable registration, such as a subscription, listener, or callback.
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.testserver.scheduling
-
Classes in io.fluxcapacitor.common used by io.fluxcapacitor.testserver.websocketClassDescriptionA
Function
that memoizes (caches) its results by key.Enumerates the types of messages recognized and routed by the Flux platform.