[rabbitmq-discuss] flow control in rabbitmq

[sandeep kumar]

Hi ,

I m using rabbitmqserver v 3.2.0
Scenario 1:
I continously sent messages to rabbitMQ Server using basic publish()
without "publisher confirms".
when the memory limit is breached by the server, the connections are
getting blocked.
Even after the connections are blocked, for some interval of time, i see
publish() being successful .
Those successfully published messages which are sent after blocked
connection are neither in queue nor in rdq files

Is the message loss expected?

Scenario 2:

I continously sent messages to server using basic publish() with "publisher
confirms" for each message.
when the memory limit is breached by the server the connections are getting
blocked.
Even after the connections are blocked, for some interval of time, i see
publish() being successful .
Those successfully published messages which are sent after blocked
connection are neither in queue nor in rdq files
There is message loss and the rate of message publishing is dropping
drastically by 80 to 90 percent if we use " publisher confirms"

Is this expected?

If these  are expected behaviours, how do we avoid message loss ?




On Mon, Dec 30, 2013 at 3:33 PM, sandeep kumar <sandy.sandeeep at gmail.com>wrote:

> Hi ,
>
> I have used single rabbitmq node , And I set  memory_high_watermark to a
> small value(0.05)
> and messages are being sent to the rabbitmq node at a higher rate.
> When memory is about to be breached because of higher rate of messages to
> the node creation of .rdq files is observed.
> when the memory consumtion crosses the limit all connections to the node
> getting blocked is observed.
> At this point of time there is neither increase in queue size nor .rdq
> size, but publish to queue statemt is getting executed.
>
> Questions are :
>
> where are the published messages are getting store when connections to
> queue are in blocked state
>
> how to handle this kind of scenario gracefully
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140103/fbf562c8/attachment.html>