Package io.fluxcapacitor.javaclient.tracking

Class NoOpFlowRegulator

java.lang.Object
io.fluxcapacitor.javaclient.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:

  • FlowRegulator.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 Flux Capacitor 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:

  • Constructor Details

    • NoOpFlowRegulator

      public NoOpFlowRegulator()