2017-10-30 4 views
0

アムのRabbitMQからのメッセージを消費しますが、消費者は、その後セロリ

 
[MainProcess] Received message: RT @Iamsidneyy: Kenya in scientific terms 

[WARNING/MainProcess] Received and deleted unknown message. Wrong destination?!? 

The full contents of the message body was: body: 'The greatest enemy of knowledge is not ignorance, it is the illusion of knowledge.\n\n—Stephen Hawking' (133b) 
{content_type:'application/json' content_encoding:'utf-8' 
    delivery_info:{'consumer_tag': 'None5', 'delivery_tag': 1, 'redelivered': False, 'exchange': 'twitterstatus', 'routing_key': 'twitterstatus'} headers={}} 


[MainProcess] Received message: RT @fideloper: Coming together! 

[WARNING/MainProcess] Received and deleted unknown message. Wrong destination?!? 

The full contents of the message body was: body: 'Lol all of mine are memes :’)' (60b) 
{content_type:'application/json' content_encoding:'utf-8' 
    delivery_info:{'consumer_tag': 'None5', 'delivery_tag': 2, 'redelivered': False, 'exchange': 'twitterstatus', 'routing_key': 'twitterstatus'} headers={}} 

答えて

0

celery worker -A app -Q twitterstatus -l info 
を使用していた次のメッセージを拒否し、その後受け入れる(同じ形式で)その後、拒否受け入れ拒否1を受け入れているようですそれ今

celery worker -A app -l info 

を使用してそのように作られた

が正常に動作キューオプションを使用してのように思える