Helpers for enriching envelopes with standardized DLQ metadata.
The canonical location for DLQ state is:
[:metadata :dlq]This metadata is designed to be portable across sinks (logger/storage/producer) and across replay mechanisms.
Helpers for enriching envelopes with standardized DLQ metadata. The canonical location for DLQ state is: - `[:metadata :dlq]` This metadata is designed to be portable across sinks (logger/storage/producer) and across replay mechanisms.
(enrich-for-deadletter envelope ctx)Adds/updates DLQ metadata on envelope.
Adds/updates DLQ metadata on `envelope`.
(ensure-envelope x)Coerces x into an envelope-ish map if it isn't already one.
Coerces `x` into an envelope-ish map if it isn't already one.
(payload-hash envelope raw-payload)Computes a stable payload hash for DLQ identification/deduplication.
Computes a stable payload hash for DLQ identification/deduplication.
(raw-payload-meta payload)Returns a portable representation for a raw payload.
Returns a portable representation for a raw payload.
- bytes -> {:format :bytes-base64 :data <string>}
- string -> {:format :string :data <string>}
- nil -> nilcljdoc 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 |