Package io.fluxcapacitor.common.api.tracking

Class DisconnectTracker

java.lang.Object
io.fluxcapacitor.common.api.Request
io.fluxcapacitor.common.api.Command
io.fluxcapacitor.common.api.tracking.DisconnectTracker
All Implemented Interfaces:
JsonType
public class DisconnectTracker extends Command
Command used to explicitly disconnect a tracker from the Flux platform and release any claimed message segments.

This is typically only used in advanced scenarios, such as when working with external trackers that integrate with Flux via long-polling or custom message ingestion mechanisms.

Use Cases

  • Releasing a segment claim manually, especially when the tracker may not shut down gracefully
  • Forcing rebalancing of segment claims across multiple tracker instances
  • Implementing robust external consumer management (e.g. using webhooks or polling APIs)

Segment Reassignment

When a tracker is disconnected, any claimed segments are released and may be reassigned to other trackers.

Optional Final Notification

If sendFinalEmptyBatch is true, a final empty MessageBatch is sent to the tracker prior to disconnection. This allows graceful shutdown or checkpointing.
See Also:

  • Constructor Details

    • DisconnectTracker

      public DisconnectTracker()

  • Method Details

    • routingKey

      public String routingKey()
      Description copied from class: Command
      Optionally specifies a routing key for this command, which may be used to partition work or apply consistent hashing when processed in the Flux platform.
      Overrides:
      routingKey in class Command
      Returns:
      a routing key string, or null if not specified