Matthias -- I'm not sure how I'm seeing them in the queue list when there are no consumers. And relatedly perhaps, the broker will crash after 20 hours or so when it runs out of memory, which confuses me as the queue lengths are always 0.<div>
<br></div><div>Here's my steps using the following code:<div><br></div><div><a href="http://notes.variogr.am/post/143623387/broadcasting-your-logs-with-rabbitmq-and-python">http://notes.variogr.am/post/143623387/broadcasting-your-logs-with-rabbitmq-and-python</a><br>
<div><br></div><div>1) Declare a Producer() and start sending messages </div><div> - this does a channel access request, declares the fanout exchange w/ auto_delete=True, then declares the "logger" queue with exclusive False and auto_delete as True, then binds the exchange and the queue</div>
<div><br></div><div>At this point logger shows up in list_queues with 0 messages. There are about 8 machines all writing messages to the queue (using immediate=True on basic_publish.) There are no consumers at this point but the queue "logger" is in the list.</div>
<div><br></div><div>2) Declare a few Consumers() </div><div> - this does the same channel access request, declare, bind as the Producer() -- same auto_delete and etc except the queue name is now "logger-randomUUID" per Conusmer</div>
<div><br></div><div>At this point logger and any logger-randomUUID show up in the list_queues. Each has 0 messages, always. Everything works as it should... consumers get messages from the Producers, queue size stays 0. </div>
<div><br></div><div>But...</div><div><br></div><div>Memory keeps going up -- and eventually the broker will crash. Yesterday it lasted about 20 hours. I booted it again this a.m. and am testing with abnormal message loads (sending millions of messages.) Right now memory is at 3.9% and increasing after only running 30m.</div>
<div><br></div><div>I am using a newer version on the server, yes, and I will do a test on the release version to see if that behavior changes. But my guess is I am doing something else wrong in my queue setup.</div><div>
<br></div><div><br></div><div><br></div><div><br></div><div><br></div></div></div>