Class NoOpFlowRegulator

java.lang.Object

io.fluxzero.sdk.tracking.NoOpFlowRegulator

All Implemented Interfaces:

FlowRegulator

public class NoOpFlowRegulator
extends Object
implements FlowRegulator

A no-op implementation of the FlowRegulator interface that never requests a pause.

This regulator allows the consumer to fetch and consume messages without any delay or throttling. It is the default regulator used in most cases, where message flow is unbounded or externally managed (e.g. through batch sizes, thread limits, or backpressure at other levels).

Behavior:

• pauseDuration() always returns Optional.empty(), indicating the consumer should never pause.
• Ideal for high-throughput scenarios where flow regulation is unnecessary or handled outside the Fluxzero Runtime.
• Thread-safe and stateless — a single shared instance is used throughout the application.

Usage Example

This is the default unless overridden in Consumer or ConsumerConfiguration.

See Also:

• FlowRegulator

Constructor Summary

Constructors

Constructor	Description
NoOpFlowRegulator()

Method Summary

Modifier and Type	Method	Description
Optional<Duration>	pauseDuration()	Optionally pause this consumer for a given amount of time.

Methods inherited from class Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

NoOpFlowRegulator

public NoOpFlowRegulator()

Method Details

pauseDuration

public Optional<Duration> pauseDuration()

Description copied from interface: FlowRegulator

Optionally pause this consumer for a given amount of time. During this time the consumer will not fetch or consume any messages.

After the given pause duration, this method will be called again to determine if fetching should continue or be paused for longer – i.e., the consumer will not continue until this method returns an empty optional.

Specified by:

pauseDuration in interface FlowRegulator