Package io.fluxzero.sdk.tracking
package io.fluxzero.sdk.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 aConsumerwithin a Fluxzero application.Configuration class that defines how a message consumer behaves during message tracking and handler invocation.Default implementation of theTrackinginterface 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.ABatchInterceptorthat ensures the correctFluxzeroinstance is bound to the current thread for the duration of aMessageBatch.A specializedRetryingErrorHandlerthat 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 defaultErrorHandlerimplementation used by Fluxzero consumers.ABatchInterceptorspecialization that transforms aMessageBatchbefore it is passed to the consumer for processing.A no-op implementation of theFlowRegulatorinterface that never requests a pause.AnErrorHandlerimplementation that retries failed operations a configurable number of times, with optional propagation or suppression of unrecoverable errors.AnErrorHandlerimplementation that suppresses all processing errors and allows message tracking to continue.ABatchInterceptorthat stalls batch processing until a minimum desired batch size is reached or a timeout occurs.AnErrorHandlerimplementation that forcefully halts message tracking by throwing any encountered errors.Represents the client-side tracking context during message consumption in Fluxzero.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 Fluxzero.Indicates that a message payload class can handle itself as a message handler.