[rabbitmq-discuss] Persister crashes Rabbit

[Matthias Radestock]

Aman,

Aman Gupta wrote:
>> The flow control in that version should tell the producers to stop
>> sending messages when memory becomes critical. However, it does require
>> a cooperating client. Hence my question above about what client you are
>> using. At present the trunk version of the Java client is the only one
>> that handles flow control correctly.
> 
> Do I just need to send a Basic.Qos(prefetch_count: 1, global: true) ?

No. Basic.Qos allows the consumer to control the flow of messages from 
the broker. That's still on our todo list. The upcoming release of the 
broker implements one half of AMQP's channel.flow, where the broker 
tells clients to stop sending messages when it is overloaded.

See Ben's article at

http://hopper.squarespace.com/blog/2008/11/9/flow-control-in-rabbitmq.html

for more details.


Matthias.