Package outbox.dispatch

Interface InFlightTracker

All Known Implementing Classes:
DefaultInFlightTracker
public interface InFlightTracker
Tracks in-flight events to prevent duplicate concurrent dispatch of the same event.
See Also:

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    release(String eventId)
    Releases processing rights, allowing the event to be dispatched again.
    boolean
    tryAcquire(String eventId)
    Attempts to acquire exclusive processing rights for the given event.

  • Method Details

    • tryAcquire

      boolean tryAcquire(String eventId)
      Attempts to acquire exclusive processing rights for the given event.
      Parameters:
      eventId - the event ID to acquire
      Returns:
      true if acquired, false if already in flight

    • release

      void release(String eventId)
      Releases processing rights, allowing the event to be dispatched again.
      Parameters:
      eventId - the event ID to release