Ah, if I do both<div><span class="Apple-style-span" style="font-family: arial, sans-serif; font-size: 13px; border-collapse: collapse; "><div><br></div><div> ch.exchange_declare(my_exchange, 'fanout', durable=False, auto_delete=False)</div>
<div> qname, n_msgs, n_consumers = ch.queue_declare(queue_name, durable=False, exclusive=False, auto_delete=True)</div><div>and send the message as immediate</div><div><div><br></div><div> def message(self, message):</div>
<div> self.ch.basic_publish(</div><div> amqp.Message(pickle.dumps(message)),</div><div> my_exchange, "logger", immediate=True</div><div> )</div></div></span><div><br></div><div>
Then it works the way I expect. </div><div><br></div><div><br></div><div><br></div><br><div class="gmail_quote">On Mon, Jul 20, 2009 at 12:36 PM, Brian Whitman <span dir="ltr"><<a href="mailto:brian@echonest.com">brian@echonest.com</a>></span> wrote:<br>
<blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex;">Hmm... this is not working the way I expect. <div><br></div><div>If I do either Holger or Matthias's solution the write-only "logger" queue continues to grow but the listener queues do stay at 0:</div>
<div><br>
</div><div><div class="im"><div>~/rabbitmq-server/scripts# ./rabbitmqctl list_queues name mode messages messages_ready messages_unacknowledged durable</div><div>Listing queues ...</div></div><div>logger_2b02ca30-754b-11de-99c0-0023dfde57d8<span style="white-space:pre"> </span>mixed<span style="white-space:pre"> </span>0<span style="white-space:pre"> </span>0<span style="white-space:pre"> </span>0<span style="white-space:pre"> </span>false</div>
<div>logger<span style="white-space:pre"> </span>mixed<span style="white-space:pre"> </span>110<span style="white-space:pre"> </span>110<span style="white-space:pre"> </span>0<span style="white-space:pre"> </span>false</div>
<div><br></div><div>What I would like to see here is that logger is always 0 messages. If there are listeners or not, I don't want the queue called "logger" to ever retain any messages. </div><div><br></div>
<div>For both "logger" (write only) and the random queue names (read only) I am doing</div><div><br></div><div><div> ch.exchange_declare(my_exchange, 'fanout', durable=False, auto_delete=False)</div>
<div>
qname, n_msgs, n_consumers = ch.queue_declare(queue_name, durable=False, exclusive=False, auto_delete=True)</div><div><br></div><div><br></div></div><div><br></div><div><br></div></div><div><div></div><div class="h5">
<div><br></div><div><br><br><div class="gmail_quote">
On Mon, Jul 20, 2009 at 12:20 PM, Matthias Radestock <span dir="ltr"><<a href="mailto:matthias@lshift.net" target="_blank">matthias@lshift.net</a>></span> wrote:<br><blockquote class="gmail_quote" style="margin:0 0 0 .8ex;border-left:1px #ccc solid;padding-left:1ex">
Brian, Holger,<br>
<div><br>
Holger Hoffstätte wrote:<br>
> Brian Whitman wrote:<br>
>> I am concerned about this because over the weekend the broker crashed<br>
>> (not sure why yet, but I assume it had something to do with probably<br>
>> ~50m messages sitting in the exchange.) How can I have messages be<br>
>> completely transient?<br>
><br>
> This is done with the "immediate" flag for a message; if there is no<br>
> recipient, the message will be dropped.<br>
<br>
</div>Actually, generally a better solution to the problem is to ensure that<br>
the queues do not outlive the consumers - by either marking them<br>
exclusive (if you only have one consumer per queue) or auto-delete.<br>
<br>
That way messages do really get dropped silently when there are no<br>
consumers. By contrast, when setting 'immediate' the server will send a<br>
basic.return to the producer.<br>
<br>
And buffering can still take place to deal with temporarily<br>
backlogged/slow consumers. By contrast, with 'immediate' the messages<br>
will get dropped when the consumers are busy (not just when they are not<br>
present).<br>
<br>
<br>
Regards,<br>
<font color="#888888"><br>
Matthias.<br>
</font><div><div></div><div><br>
_______________________________________________<br>
rabbitmq-discuss mailing list<br>
<a href="mailto:rabbitmq-discuss@lists.rabbitmq.com" target="_blank">rabbitmq-discuss@lists.rabbitmq.com</a><br>
<a href="http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss" target="_blank">http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss</a><br>
</div></div></blockquote></div><br></div>
</div></div></blockquote></div><br></div>