Common Utilities - kombu.common¶
kombu.common¶
Common Utilities.
| copyright: |
|
|---|---|
| license: | BSD, see LICENSE for more details. |
- class kombu.common.Broadcast(name=None, queue=None, **kwargs)¶
Convenience class used to define broadcast queues.
Every queue instance will have a unique name, and both the queue and exchange is configued with auto deletion.
Parameters: - name – This is used as the name of the exchange.
- queue – By default a unique id is used for the queue name for every consumer. You can specify a custom queue name here.
- **kwargs – See Queue for a list of additional keyword arguments supported.
- kombu.common.entry_to_queue(queue, **options)¶
- kombu.common.maybe_declare(entity, channel)¶
