[rabbitmq-discuss] rabbitmq-c TTL setting not working for me - please help
Kim Tran
ktran0003 at gmail.com
Tue Jun 17 17:59:26 BST 2014
Simon,
Thanks for the hints. I didn't have the basic.qos to receive one at a
time. That's likely the reason.
So what would happen if I got all the messages straight away but slowly
process them: the queue would get bigger and bigger over time? and
eventually crash with some socket error?
Thanks,
-Kim
On 6/17/2014 9:39 AM, Simon MacMullen wrote:
> On 17/06/2014 5:33PM, Kim Tran wrote:
>> And I still got all the messages. None of them was dropped.
>
> Hang on. You originally said:
>
>> Then every time I consume a message, I sleep for 5 secs just to delay
>> the consuming rate.
>
> That would mean the broker sent you all the messages straight away,
> but your app delayed reading them off the socket. The queue can't
> expire messages when they are out for delivery.
>
> So if you want a slow consumer, set basic.qos to a low value (e.g. 1),
> that way the broker will only send you one message at a time as you
> acknowledge them (you are using acks, right?)
>
> Then you should see the messages expire.
>
> Cheers, Simon
>
More information about the rabbitmq-discuss
mailing list