celery -A proj control add_consumer foo -d worker1.local
可以使用app.control.add_consumer()
方法动态地完成相同的操作:
app.control.add_consumer('foo', reply=True)
[{u'worker1.local': {u'ok': u"already consuming from u'foo'"}}]
app.control.add_consumer('foo', reply=True,
destination=['worker1@example.com'])