<div dir="ltr"><div>I have 4 hosts connected with 4 queues to the RabbitMQ service. I have multiple processes making calls to each host using the queues, but what happens is that messages overlap giving me errors of execution. What should I do to prevent the processes do not overlap messages with the MQ using celery?</div><div><br></div><div>host1 <--queue1 -|</div><div>host2 <--queue2 -|--> MQ</div><div>host3 <--queue3 -|</div><div>host4 <--queue4 -|</div><div><br></div><div><br></div><div>Error because messages are overlapping.</div><div>  File "/usr/local/lib/python2.7/dist-packages/amqp/connection.py", line 526, in _close</div><div>    (class_id, method_id), ConnectionError)</div><div>UnexpectedFrame: Basic.publish: (505) UNEXPECTED_FRAME - expected content header for class 60, got non content header frame instead</div></div>