Interface DeadLetterQueue

All Known Implementing Classes:
InMemoryDeadLetterQueue

public interface DeadLetterQueue
Contract for storing failed operations that exceeded resilience policies.
  • Method Details

    • enqueue

      void enqueue(DeadLetterEntry entry)
      Stores a failed entry.
      Parameters:
      entry - Entry to store
    • getEntries

      List<DeadLetterEntry> getEntries()
      Returns all entries in the queue.
    • getEntries

      List<DeadLetterEntry> getEntries(String operationId)
      Returns entries filtered by operation ID.
    • size

      int size()
      Returns the current entry count.