[rabbitmq-discuss] Updating messages on queues
carl.bourne at intellect.co.uk
Mon Jul 19 12:22:12 BST 2010
Matthew Sackman-3 wrote:
> On Mon, Jul 19, 2010 at 04:06:38AM -0700, cbourne wrote:
>> > So by this I mean adding some kind of a time field to the header so the
>> > consumer can apply a time based filter to the messages. Basically I
>> need a
>> > retry queue that allows messages to be re-processed after a pre-defined
>> > time if the first attempt failed. Ideally this would also include the
>> > number of times to try before failing permanently.
> Well, you could always just handle it completely in the consumer - if
> the consumer can't process it, republish the message with an update try
> count and then ack the original message. Because the publish will go to
> the end of the queue, that'll ensure that new messages do get seen and
> that a repeatedly failing message doesn't ensure that other messages get
> starved of attention.
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
Thanks Matt - guess the only problem with getting the consumer to do this is
that if it's the consumer that fails, then the message could be lost. Would
be better to leave the message on the queue so it could at least be
processed by a different consumer if that were to happen. Hence, the
requirement to update a field in the message header.
View this message in context: http://old.nabble.com/Updating-messages-on-queues-tp29203202p29203617.html
Sent from the RabbitMQ mailing list archive at Nabble.com.
More information about the rabbitmq-discuss