別のアプリケーションのセロリキューからコンシューマする方法

Question

Celeryを使用してRabbitMQにAPIコールを挿入するための私のプロデューサアプリケーションには、以下のコードがあります。

celery.send_task('tasks.process_redox', (payload,), queue="redox_inbound") 

私は、そのキューから消費するコードはどのように見えますか？あなたはそのキューを監視するためにセロリを指示する必要があり

@celery.task() 
def process_redox(payload): 
    data = encrypter.decrypt(payload) 
    print data 
    return 

Answer 1

でそれを見つけることができないよう、私は以下の持っているが、それは動作しません。

app.conf.task_queues = (
    Queue('redox_inbound', routing_key='default'), 
) 

http://docs.celeryproject.org/en/latest/userguide/routing.html#manual-routing