[rabbitmq-discuss] Broker leak with MulticastMain?

Tue Jul 15 12:03:40 BST 2008

I just realized that I could call the stat_all() functions while the test 
is running :-)

--snip--

(rabbit at tux)2> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)3> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)4> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)5> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)6> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)7> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)8> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)9> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)10> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)11> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)12> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      0,1}]
(rabbit at tux)13> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      1858,0}]
(rabbit at tux)14> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      2328,0}]
(rabbit at tux)15> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      3203,0}]
(rabbit at tux)16> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      3784,0}]
(rabbit at tux)17> rabbit_amqqueue:stat_all().
[{ok,{resource,<<"/">>,queue,
                <<"amq.gen-ktU1xAvf7t5rKxDBpsCbgg==">>},
      4279,0}]
(rabbit at tux)18>

--snip--

There is no queue leak and the first few calls always return 0,1 (what are 
those?) but then suddenly the first number starts to grow, just as the 
latencies printed from the Java client start to increase.

Hope this helps.

Holger