Skip to content

Commit

Permalink
confirm error (celery#3840)
Browse files Browse the repository at this point in the history
  • Loading branch information
baixuexue123 authored and Omer Katz committed Mar 2, 2017
1 parent faaa949 commit 64d0a09
Showing 1 changed file with 6 additions and 1 deletion.
7 changes: 6 additions & 1 deletion docs/userguide/routing.rst
Original file line number Diff line number Diff line change
Expand Up @@ -676,7 +676,12 @@ copies of tasks to all workers connected to it:
from kombu.common import Broadcast
app.conf.task_queues = (Broadcast('broadcast_tasks'),)
app.conf.task_routes = {'tasks.reload_cache': {'queue': 'broadcast_tasks'}}
app.conf.task_routes = {
'tasks.reload_cache': {
'queue': 'broadcast_tasks',
'exchange': 'broadcast_tasks'
}
}
Now the ``tasks.reload_cache`` task will be sent to every
worker consuming from this queue.
Expand Down

0 comments on commit 64d0a09

Please sign in to comment.