Transport-agnostic DLQ administration.
Implementations are responsible for fetching and updating DLQ records using a durable backing store (storage is the default source of truth).
Transport-agnostic DLQ administration. Implementations are responsible for fetching and updating DLQ records using a durable backing store (storage is the default source of truth).
(get-deadletter this dlq-id opts)Fetch a DLQ record by dlq-id.
Fetch a DLQ record by dlq-id.
(list-deadletters this query opts)List DLQ records.
query:
returns {:ok true :items [...]} or {:ok false :error ...}
List DLQ records.
query:
- :topic (keyword|string, optional)
- :status (keyword, optional)
- :limit (int, optional)
returns {:ok true :items [...]} or {:ok false :error ...}(mark-deadletter! this dlq-id status opts)Update DLQ status (e.g. :manual/:stuck/:poison/:eligible).
Update DLQ status (e.g. :manual/:stuck/:poison/:eligible).
(replay-deadletter! this dlq-id opts)Replay a DLQ record by dlq-id. Implementations should use generic producer APIs when possible.
Replay a DLQ record by dlq-id. Implementations should use generic producer APIs when possible.
cljdoc builds & hosts documentation for Clojure/Script libraries
| Ctrl+k | Jump to recent docs |
| ← | Move to previous article |
| → | Move to next article |
| Ctrl+/ | Jump to the search field |