diff options
| author | Ask Solem <ask@celeryproject.org> | 2015-11-24 13:37:48 -0800 |
|---|---|---|
| committer | Ask Solem <ask@celeryproject.org> | 2015-11-24 13:37:48 -0800 |
| commit | 45ac835e97ade8fac5a7ab9ba8959d60c844954d (patch) | |
| tree | 906976a65da7d6897b6fdd37441790346ad95fa7 /docs/reference | |
| parent | e5b5b58234d1efbcf79c49949bd26bb68cd1f12f (diff) | |
| download | kombu-45ac835e97ade8fac5a7ab9ba8959d60c844954d.tar.gz | |
Redis: Adds queue_order_strategy transport option (Closes #518).
Order in which we consume from queues.
Can be either string alias, or a cycle strategy class
- ``round_robin``
:class:`~kombu.utils.scheduling.round_robin_cycle``
Make sure each queue has an equal opportunity to be consumed from.
- ``sorted``
:class:`~kombu.utils.scheduling.sorted_cycle`.
Consume from queues in alphabetical order.
If the first queue in the sorted list always contains messages,
then the rest of the queues will never be consumed from.
- ``priority``
:class:`~kombu.utils.scheduling.priority_cycle`.
Consume from queues in original order, so that if the first
queue always contains messages, the rest of the queues
in the list will never be consumed from.
The default is to consume from queues in round robin.
Diffstat (limited to 'docs/reference')
| -rw-r--r-- | docs/reference/kombu.transport.virtual.scheduling.rst | 7 | ||||
| -rw-r--r-- | docs/reference/kombu.utils.scheduling.rst | 7 |
2 files changed, 7 insertions, 7 deletions
diff --git a/docs/reference/kombu.transport.virtual.scheduling.rst b/docs/reference/kombu.transport.virtual.scheduling.rst deleted file mode 100644 index 5eca4b91..00000000 --- a/docs/reference/kombu.transport.virtual.scheduling.rst +++ /dev/null @@ -1,7 +0,0 @@ -.. contents:: - :local: -.. currentmodule:: kombu.transport.virtual.scheduling - -.. automodule:: kombu.transport.virtual.scheduling - :members: - :undoc-members: diff --git a/docs/reference/kombu.utils.scheduling.rst b/docs/reference/kombu.utils.scheduling.rst new file mode 100644 index 00000000..7efb54e9 --- /dev/null +++ b/docs/reference/kombu.utils.scheduling.rst @@ -0,0 +1,7 @@ +.. contents:: + :local: +.. currentmodule:: kombu.utils.scheduling + +.. automodule:: kombu.utils.scheduling + :members: + :undoc-members: |
