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'])


