This document is for Kombu's development version, which can be significantly different from previous releases. Get the stable docs here: 5.3.

Native Delayed Delivery - native_delayed_delivery

Added in version 5.5.

Native Delayed Delivery API.

Only relevant for RabbitMQ.

kombu.transport.native_delayed_delivery.bind_queue_to_native_delayed_delivery_exchange(connection: Connection, queue: Queue) → None

Binds a queue to the native delayed delivery exchange.

kombu.transport.native_delayed_delivery.calculate_routing_key(countdown: int, routing_key: str) → str

Calculate the routing key for publishing a delayed message based on the countdown.

kombu.transport.native_delayed_delivery.declare_native_delayed_delivery_exchanges_and_queues(connection: Connection, queue_type: str) → None

Declares all native delayed delivery exchanges and queues.

kombu.transport.native_delayed_delivery.level_name(level: int) → str

Generates the delayed queue/exchange name based on the level.