[rabbitmq-discuss] Spring amqp - auto acknowledge from consumer taking almost a minute

[Gary Russell]

If your consumer(s) can't keep up with the workload, things are eventually
going to queue up somewhere; you are just moving the problem somewhere else.

Do you have enough resources to run multiple consumers?

Set concurrentConsumers=n to increase the number of consumers in the
listener container.


On Fri, Mar 28, 2014 at 5:09 PM, Anita Yip <Anita.Yip at realpage.com> wrote:

>   The only problem is my consumer has heavy processing, and the messages
> are hanging in the queue, the queue size keep growing thus finally
> resulting in Out of Memory error.
>
>   From: Gary Russell <grussell at gopivotal.com>
> Reply-To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
> Date: Friday, March 28, 2014 1:56 PM
> To: Discussions about RabbitMQ <rabbitmq-discuss at lists.rabbitmq.com>
> Subject: Re: [rabbitmq-discuss] Spring amqp - auto acknowledge from
> consumer taking almost a minute
>
>   Your requirements seem to be a little unusual - you want the consumer
> to ack as soon as you get the message but before the processing completes.
>
>  What if your consumer dies right after it acks - you'll still lose the
> message in that case.
>
>  If you don't care about that situation, simply hand off the task to
> another thread in your listener and the container will ack the message
> right after the handoff (with ackmode AUTO).
>
>  What is the objection to it being "unacked" until the consumer completes
> the work?
>
>  Gary
>
>
> On Fri, Mar 28, 2014 at 4:49 PM, Anita Yip <Anita.Yip at realpage.com> wrote:
>
>> Does that mean no explicit acknowledgement is sent by consumer? What if
>> the message is lost before it reaches the consumer? When will the message
>> be removed from the queue in this case?
>>
>>
>>
>> On 3/28/14 12:06 AM, "Michael Klishin" <mklishin at gopivotal.com> wrote:
>>
>> >On 28 March 2014 at 10:06:21, Anita Yip (anita.yip at realpage.com) wrote:
>> >> > I see all the messages falling under "Deliver (noack)". Doesn't
>> >> this mean that RabbitMq is not expecting/processing any
>> >>acknowledgements
>> >> from the consumer?
>> >
>> >Correct. A message is then considered to be processed  as soon as
>> RabbitMQ
>> >sends it out.
>> >--
>> >MK
>> >
>> >Software Engineer, Pivotal/RabbitMQ
>> >_______________________________________________
>> >rabbitmq-discuss mailing list
>> >rabbitmq-discuss at lists.rabbitmq.com
>> >https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>>
>>
>> ________________________________
>>
>> This message is intended only for the use of the individual(s) or entity
>> to which it is addressed and may contain information that is privileged,
>> confidential, and/or proprietary to RealPage and its affiliated companies.
>> If the reader of this message is not the intended recipient, you are hereby
>> notified that any dissemination, distribution, forwarding or copying of
>> this communication is prohibited without the express permission of the
>> sender. If you have received this communication in error, please notify the
>> sender immediately and delete the original message.
>> _______________________________________________
>> rabbitmq-discuss mailing list
>> rabbitmq-discuss at lists.rabbitmq.com
>> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>>
>
>
> ------------------------------
>
> This message is intended only for the use of the individual(s) or entity
> to which it is addressed and may contain information that is privileged,
> confidential, and/or proprietary to RealPage and its affiliated companies.
> If the reader of this message is not the intended recipient, you are hereby
> notified that any dissemination, distribution, forwarding or copying of
> this communication is prohibited without the express permission of the
> sender. If you have received this communication in error, please notify the
> sender immediately and delete the original message.
>
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20140328/aaa1c54b/attachment.html>