<div class="gmail_extra">Thanks for that brilliant idea. I didn't know aboud these extensions.</div><div class="gmail_extra"><br></div><div class="gmail_extra">Best regards, Ostin.<br><br><div class="gmail_quote">27 апреля 2012 г. 13:03 пользователь Steve Powell <span dir="ltr"><<a href="mailto:steve@rabbitmq.com" target="_blank">steve@rabbitmq.com</a>></span> написал:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">Ostin,<br>
It is not clear to me what you are 'watching' these queues for, but if<br>
you want to retrieve the message from the queues after a certain time,<br>
then why not investigate Dead Letter Exchanges(DLX) and queue message<br>
expiry?<br>
<br>
If the moderator's private queues have an expiry time (TTL) on them,<br>
then messages that have been on the queue for that time will be deleted<br>
-- if there is a DeadLetterExchange associated with the queues, the<br>
deleted message will be re-published to the new exchange. You can<br>
arrange for the DLX to route the message to a queue of your choice --<br>
the monitor process need only listen on this queue.<br>
<br>
Be sure to code the moderator carefully (so as not to drop a message<br>
while moving it) using publisher confirms and acks.<br>
<br>
See<br>
(<a href="http://www.rabbitmq.com/extensions.html/#dead-letter-exchanges" target="_blank">http://www.rabbitmq.com/extensions.html/#dead-letter-exchanges</a>)<br>
and<br>
(<a href="http://www.rabbitmq.com/extensions.html/#queue-ttl" target="_blank">http://www.rabbitmq.com/extensions.html/#queue-ttl</a>)<br>
for more information.<br>
<br>
Steve Powell<br>
<a href="mailto:steve@rabbitmq.com">steve@rabbitmq.com</a><br>
[wrk: +44-2380-111-528] [mob: +44-7815-838-558]<br>
<div><div class="h5"><br>
On 21 Apr 2012, at 00:46, Alexey Ostin wrote:<br>
<br>
> Let me show one more example.<br>
><br>
> I've got some moderation queue. Whenever a moderator locks message (or several messages) for moderation, it moves from main queue to personal moderator's queue. Just to perform some long time lock (It can be minute or hour, thus I can't use ack/nack to hold message in main queue). The goal is to monitor all moderators queues as well as main one. The problem is that I do not know all moderator's queues and I can't just monitor some fixed list because it regenerates dynamically.<br>
><br>
> I've just thought about using separate exchange for moderator's queues. It can help with monitoring, I'd watch over whole exchange.<br>
> But it is still interesting whether I can publish message to several queues and consume it from them all at once. Sounds like gibberish.<br>
><br>
> To be honest I've got one more problem to solve - it is to automatically release these locks (put a message from moderator's queue back to main) by timeout, but it should be other conversation I think :)<br>
><br>
> Best regards, Ostin.<br>
><br>
> 20 апреля 2012 г. 21:00 пользователь Simon MacMullen <<a href="mailto:simon@rabbitmq.com">simon@rabbitmq.com</a>> написал:<br>
> On 20/04/12 17:27, ostin wrote:<br>
> Example application with topic exchange:<br>
> I push a message to server1.app1 queue and an other one to<br>
> server1.app2 queue. I monitor server1 queue to determine count of<br>
> processing messages on server 1. After app1 ends processing message it<br>
> shold be deleted from both queues: from app1 to prevent duplicate<br>
> processing, from server1 to have valid stats for monitoring. I assume<br>
> that there can be many applications with random names, so I cant<br>
> monitor just count of messages in app* queues.<br>
><br>
> If you want to make sure that a given message is only ever consumed from server1.app1 OR server1.app2, why not have only a single queue and have both applications consume from it?<br>
><br>
> Cheers, Simon<br>
><br>
> --<br>
> Simon MacMullen<br>
> RabbitMQ, VMware<br>
><br>
</div></div>> _______________________________________________<br>
> rabbitmq-discuss mailing list<br>
> <a href="mailto:rabbitmq-discuss@lists.rabbitmq.com">rabbitmq-discuss@lists.rabbitmq.com</a><br>
> <a href="https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
<br>
</blockquote></div><br></div>