DelayedDelivery
Bootstep that sets up native delayed delivery functionality.
Attributes
| Attribute | Type | Description |
|---|---|---|
| requires | tuple = (Tasks,) | A tuple containing the bootsteps that must be initialized before this component can start, specifically requiring the Tasks step. |
Methods
include_if()
@classmethod
def include_if(
c: [Consumer](../../consumer/consumer.md?sid=celery_worker_consumer_consumer_consumer)
) - > bool
Determine if this bootstep should be included.
Parameters
| Name | Type | Description |
|---|---|---|
| c | [Consumer](../../consumer/consumer.md?sid=celery_worker_consumer_consumer_consumer) | The Celery consumer instance |
Returns
| Type | Description |
|---|---|
bool | True if quorum queues are detected, False otherwise |
start()
@classmethod
def start(
c: [Consumer](../../consumer/consumer.md?sid=celery_worker_consumer_consumer_consumer)
) - > None
Initialize delayed delivery for all broker URLs.
Parameters
| Name | Type | Description |
|---|---|---|
| c | [Consumer](../../consumer/consumer.md?sid=celery_worker_consumer_consumer_consumer) | The Celery consumer instance |
Returns
| Type | Description |
|---|---|
None | null |