app.control.add_consumer('foo', reply=True)
[{'worker1.local': {'ok': "already consuming from u'foo'"}}]
app.control.add_consumer('foo', reply=True, destination=['worker1@example.com']
    )
Create dynamic queues with Celery