Hey guys,<br><br>I am suing the last rabbitmq with the Ruby Stomp adapter and I have been doing some testing.<br>A queue has been created as durable and non auto-delete. This queue has no listener as of now.<br><br>A process puts messages in a queue every second roughly. Atfer some time, I check the queue.<br>
> rabbitmqctl list_queues messages name consumers<br>Listing queues ...<br>508 /queue/MyQueue 0<br><br>Now, I start a consumer with the following code :<br><br>queue_client.subscribe("/queue/FeedsToParse", {:durable => true, "auto-delete".intern => false}) do |message|<br>
sleep 600<br> puts "done!"<br>end<br><br>As you can see, when starting this client, the number of elements in my queue should decrease pretty slowly (1 every 10 minutes)... but here is what happens if I check the queue again:<br>
> rabbitmqctl list_queues messages name consumers<br>
Listing queues ...<br>
417 /queue/MyQueue 1<br>
<br>So it seems that starting a consumer deletes some messages in the queue. I have no idea why. Can anyone explain?<br><br>Thanks a lot for your great help!<br><br>julien<br><br><br clear="all">--<br>Julien Genestoux<br>
<a href="http://www.ouvre-boite.com">http://www.ouvre-boite.com</a><br><a href="http://blog.notifixio.us">http://blog.notifixio.us</a><br><br>+1 (415) 254 7340<br>+33 (0)9 70 44 76 29<br>