Hi all,<div><br></div><div>I am facing a weird problem of losing messages, even though I am publishing them as persistent messages with&nbsp;<span class="Apple-style-span" style="font-family: palatino, georgia, verdana, arial, sans-serif; line-height: 19px; font-size: small; ">pika.BasicProperties(delivery_mode=2)</span>&nbsp;. Here is the scenario:</div><div><br></div><div>I have two RabbitMQ brokers, namely rabbit@vm11 and rabbit@vm22; &nbsp;these two are have been setup in a cluster configuration as shown below:</div><div><div>[{nodes,[{disc,[rabbit@vm11,rabbit@vm22]}]},</div><div>&nbsp;{running_nodes,[rabbit@vm22,rabbit@vm11]}]</div></div><div><br></div><div>I have two clients (written using pika.BlockingConnection() ); lets call these clients C1 and N1.</div><div>1.) C1 creates an unique exchange (exchange name generated using UUID, say 3fe546be8aa341b7b174b29a56e63797).</div><div>2.) C1 then spawns a thread, say C1-T1, which connects to rabbitmq server and waits for a response on this exchange using channel.start_consuming().&nbsp;</div><div>3.) C1 then sends a message to N1 and in the message proviodes the name of the exchange (3fe546be8aa341b7b174b29a56e63797) where N1 should send the response.</div><div>4.) once C1-T1 gets the response, it hands over the response to C1 and dies.</div><div><br></div><div>In my current setup I have 100 clients process like C1, i.e. C1, C2 ... C100 and one N1.&nbsp;</div><div><br></div><div>This setup works perfectly fine when RabbitMQ is in a single node setup but when I put it in a cluster setup, it starts to loose the messages. What I mean is that Thread C1-T1 never gets a response and time-outs writing an ERROR in my log file.&nbsp;</div><div><br></div><div>The trouble is I am loosing as high mashy as 50% of the messages.</div><div><br></div><div>could someone tell me what could be going wrong.</div><div><br></div><div>thanks in advance,</div><div>-upendra</div><div><br></div><div>Some more Details of setup:&nbsp;</div><div>RabbitMQ Server: 2.8.4</div><div>Pika Library:&nbsp;0.9.5</div><div>OS: Ubuntu 12.04 (Precise)</div><div>VM11 and VM22: quad-core machines with 8GB RAM</div><div><br></div><div>Q.) How do I know message is lost?</div><div>A.) I performed the following steps:</div><div>1.) log the message at N1 after successfully publishing it</div><div>2.) enable trace_on on rabbitMQ server and there too log the messages</div><div><br></div><div>What I found that the message was sent by N1, was received by rabbitMQ server and RabbitMQ server reports it to be published on the Excahnge&nbsp;3fe546be8aa341b7b174b29a56e63797 &nbsp;and never reports it to be delivered.&nbsp;</div><div>But when I look at the queue it reports "0" messages -- I am pasting the output of rabbitmqadmin command</div><div><div>root@vm11:~# rabbitmqadmin list queues name node messages | grep 3fe546be8aa341b7b174b29a56e63797</div><div>| 3fe546be8aa341b7b174b29a56e63797 | rabbit@vm22 | 0 &nbsp; &nbsp; &nbsp; &nbsp;|</div></div><div><br></div><div><br></div><div><br></div>