[rabbitmq-discuss] revoking or removing queued messages

Fri Jun 18 22:09:07 BST 2010

http://wiki.github.com/ask/celery/

-J

Sent via iPhone

Is your e-mail Premiere?

On Jun 18, 2010, at 14:52, Shane <shane at digitalsanctum.com> wrote:

> Alexis, I'm not familiar with Celery.
>
> On Jun 18, 10:43 am, Alexis Richardson <ale... at rabbitmq.com> wrote:
>> Shane
>>
>> How does Celery do things like this? That might be a pattern to
>> follow even if you don't want to use Celery per se.
>>
>> alexis
>>
>>
>>
>>
>>
>> On Thu, Jun 17, 2010 at 8:57 PM, Shane <sh... at digitalsanctum.com>  
>> wrote:
>>> Thanks, Scott. Something along the lines of the second approach you
>>> outlined seems like the way to go.
>>
>>> On Jun 17, 2:04 pm, Scott Brooks <sc... at beamdog.com> wrote:
>>>> I'm pretty sure there is no way to remove a message(besides a full
>>>> purge of a queue) since publishing is async so you never really  
>>>> have a
>>>> way to refer to that message.
>>
>>>> Some times changes your approach can solve the problem though.
>>>> I'm not sure what your needs are, but lets assume your are  
>>>> processing
>>>> PDF files or something like that.
>>
>>>> One approach would be to send a message containing all the text  
>>>> to be
>>>> processed as the message, which then the consumer grabs and works
>>>> with.
>>>> Another approach would be to send a message saying "document X is
>>>> ready to be processed", and the consumer then grabshttp:// 
>>>> my.pdf.processor.com/documents/X, and does the work.
>>
>>>> The second approach lets you respond with a "job canceled" message
>>>> when you request the actual document.
>>
>>>> Scott
>>
>>>> On Thu, Jun 17, 2010 at 11:38 AM, Shane  
>>>> <sh... at digitalsanctum.com> wrote:
>>>>> In our current system, we have a function that essentially  
>>>>> revokes a
>>>>> unit of work before it's acted on. In RabbitMQ, is there a way to
>>>>> revoke or remove a message from a queue assuming it hasn't been  
>>>>> acted
>>>>> on?
>>
>>>>> Thanks,
>>>>> Shane
>>>>> _______________________________________________
>>>>> rabbitmq-discuss mailing list
>>>>> rabbitmq-disc... at lists.rabbitmq.com
>>>>> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq- 
>>>>> discuss
>>
>>>> _______________________________________________
>>>> rabbitmq-discuss mailing list
>>>> rabbitmq-disc... at lists.rabbitmq.comhttp://lists.rabbitmq.com/cgi- 
>>>> bin/mailman/listinfo/rabbitmq-discuss
>>> _______________________________________________
>>> rabbitmq-discuss mailing list
>>> rabbitmq-disc... at lists.rabbitmq.com
>>> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
>>
>> _______________________________________________
>> rabbitmq-discuss mailing list
>> rabbitmq-disc... at lists.rabbitmq.comhttp://lists.rabbitmq.com/cgi- 
>> bin/mailman/listinfo/rabbitmq-discuss
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss