Package io.fluxcapacitor.javaclient.tracking
package io.fluxcapacitor.javaclient.tracking
-
ClassDescriptionIntercepts and decorates batch-level message handling for a
Tracker
.Exception thrown during message batch processing to intentionally halt tracking after a specific message.Declares aConsumer
within a Flux application.Configuration class that defines how a message consumer behaves during message tracking and handler invocation.Default implementation of theTracking
interface that coordinates message tracking for a specificMessageType
.An interface to handle errors encountered during message tracking and processing, with the ability to retry operations.Interface for controlling flow regulation in a consumer.ABatchInterceptor
that ensures the correctFluxCapacitor
instance is bound to the current thread for the duration of aMessageBatch
.A specializedRetryingErrorHandler
that retries failed operations indefinitely until they succeed.Use 48 bits of the current time in milliseconds since epoch as the base of the index.The defaultErrorHandler
implementation used by Flux Capacitor consumers.ABatchInterceptor
specialization that transforms aMessageBatch
before it is passed to the consumer for processing.A no-op implementation of theFlowRegulator
interface that never requests a pause.AnErrorHandler
implementation that retries failed operations a configurable number of times, with optional propagation or suppression of unrecoverable errors.AnErrorHandler
implementation that suppresses all processing errors and allows message tracking to continue.ABatchInterceptor
that stalls batch processing until a minimum desired batch size is reached or a timeout occurs.AnErrorHandler
implementation that forcefully halts message tracking by throwing any encountered errors.Represents the client-side tracking context during message consumption in Flux Capacitor.The Tracking interface provides a mechanism to start and manage the tracking of messages by a given set of handlers.Exception thrown during the initialization of message tracking in Flux Capacitor.Indicates that a message payload class can handle itself as a message handler.