Connectum API Reference / @connectum/events / dlqMiddleware
Function: dlqMiddleware()
dlqMiddleware(
options,adapter):EventMiddleware
Defined in: packages/events/src/middleware/dlq.ts:29
Create a DLQ middleware that catches errors from inner middleware (retry), publishes to DLQ topic, and acks the original.