[rabbitmq-discuss] Problem when enqueuing with no delay

Wed Sep 11 10:27:52 BST 2013

Hi all,

I'm testing RabbitMQ AMQP with amqp-ruby library client. The scenario is 
1 or 2 producers sending little messages from about 50 KB to one queue 
(the idea is increase this amount of KB)  and various consumers.

The problem comes when there's no delay when producer is enqueuing 
messages, this is the basic code (where variable /productor_time/ is the 
time between enqueuing messages):

[...]
               EventMachine.add_periodic_timer( productor_time ) do
                     exchange.publish message, :routing_key => "queue0", 
:persistent => (true)
                     progress(1)
              end
[...]

When /productor_time/ is 0, it seems that there is a collapse in a 
moment, and publishers are enqueuing messages but consumers don't 
dequeue message and so the RAM memory and SWAP memory increase to the 
crash of the machine. If /productor_time/ is more than 0, for example 
0.1, there's no problem and consumers dequeue messages normally.

The code for consumer:

            queue.subscribe(:ack => true) do |header, message|
                 messages << message
                 header.ack
                 progress(1)
            end

If I try with ruby-STOMP interface this problem is not present.

Do you know what is happening here?

Thanks

Cheers,

Pablo
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130911/b5af9a64/attachment.htm>