Durable function queues - registers the `durable:subscriber` trigger type and the queue/DLQ service functions.
Browse DLQ messages
List DLQ topics with counts
Internal provider for TriggerAction::Enqueue
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.
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`.
