Durable function queues - registers the `durable:subscriber` trigger type and the queue/DLQ service functions.
iiiverifiedexact versions are immutable; binary and bundle artifacts are digest-pinned.
Browse DLQ messages
List DLQ topics with counts
Internal provider for TriggerAction::Enqueue
Namespace in which the queued target must resolve. The engine sends this for non-default enqueues and omits it for legacy/default traffic.
Trace context captured by the engine at the enqueue boundary and restored when the queued function is invoked.
List all queue topics
Get stats for a queue topic
Enqueue a message
Topic to publish to. `queue` is accepted for the migration worker API.
Discard (purge) a single DLQ message by ID
Redrive all DLQ messages back to the main queue
Redrive a single DLQ message by ID back to the main queue
Define and start a durable named function queue
Base delay in milliseconds for the exponential retry backoff.
Number of messages processed concurrently.
Declares the queue as a RabbitMQ priority queue with this many priority levels (`x-max-priority`). `None` means not a priority queue. RabbitMQ-only; other adapters ignore it. Added (rather than part of the original minimal port) so [`QueueAdapter::setup_function_queue`] can pass it through to the RabbitMQ adapter's topology setup.
Maximum retries after the initial delivery before a message is sent to the dead-letter queue.
Payload field used to partition FIFO messages into independently ordered groups.
Delay between polls for adapters backed by a local store.
Payload field whose non-negative integer value supplies message priority when the adapter supports priority queues.
Re-deliver an invocation inside the same queue attempt when the engine restarts while it is in flight. This is only safe for consumers whose own durable checkpoints make duplicate delivery idempotent.
Maximum time in milliseconds allowed for one target-function invocation.
Queue scheduling mode. Supported values are `standard` and `fifo`.
Internal: reload queue configuration from the authoritative store.
Durable queue subscriber
Queue/topic name to consume.
Declares this subscriber's queue as a RabbitMQ priority queue with this many levels (`x-max-priority`, 1–255). RabbitMQ-only; the priority value of each message comes from the adapter-level `priority_field`.
