[rabbitmq-discuss] RabbitMQ 3.0 Policy ha-all delete issue

Tue Nov 20 17:02:45 GMT 2012

I should note that my testing clients are actively sending messages in 4
static queues.  but for each message sent they are creating a dynamic queue
and then later deleting the queue.  I think the issue could be happening
wile the cluster is handling some of the more volatile queues that are
created/deleted by the clients.

What else I noticed.  I deleted the previous queue that was still tied to a
policy that didn't exist.  Began running my test again with no policies. 
During the testing I created the policy to mirror the queues and received
another error.  then after a few moments of I deleted the policy.  An error
again.

Now one of my more static queues was lost. It does not show up in the
management anymore.   I think the queue "crashed"

Some of my errors from the logs

=INFO REPORT==== 20-Nov-2012::10:33:30 ===
Adding mirror of queue 'dcf.action.status' in vhost 'MoBunnyMoProblems.DCF'
on node 'rabbit at CUST1-MASTER': <2756.5031.0>

=INFO REPORT==== 20-Nov-2012::10:33:30 ===
Adding mirror of queue 'dcf.action.status' in vhost 'MoBunnyMoProblems.DCF'
on node 'rabbit at RIOBARON-1': <2754.13177.4>

=WARNING REPORT==== 20-Nov-2012::10:46:47 ===
closing AMQP connection <0.32767.3> (192.168.10.104:37880 ->
192.168.10.57:5672):
connection_closed_abruptly

=ERROR REPORT==== 20-Nov-2012::10:49:28 ===
** Generic server <0.6.4> terminating
** Last message in was stop_mirroring
** When Server state == {q,
                         {amqqueue,
                          {resource,<<"MoBunnyMoProblems.DCF">>,queue,
                           <<"dcf.action.status">>},
                          true,false,none,
                          [{<<"x-expires">>,signedint,100800000}],
                          <0.6.4>,[],[],
                          [{vhost,<<"MoBunnyMoProblems.DCF">>},
                           {name,<<"ha-all">>},
                           {pattern,<<"^dcf">>},
                           {definition,[{<<"ha-mode">>,<<"all">>}]},
                           {priority,0}],
                          []},
                         none,true,rabbit_variable_queue,
                         {vqstate,
                          {0,{[],[]}},
                          {0,{[],[]}},
                          {delta,undefined,0,undefined},
                          {0,{[],[]}},
                          {0,{[],[]}},
                          10885,
                          {0,nil},
                          undefined,
                          {0,nil},
                          {qistate,

"c:/rabbitmq.hold/db/rabbit at RIOOVERLORD-1-mnesia/queues/CTMLPLO20JY4AIHN3GGESPI7D",
                           {{dict,0,16,16,8,80,48,

{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},
                             {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                               []}}},
                            [{segment,0,

"c:/rabbitmq.hold/db/rabbit at RIOOVERLORD-1-mnesia/queues/CTMLPLO20JY4AIHN3GGESPI7D/0.idx",
                              {array,16384,0,undefined,
                               {{1000,1000,1000,1000,1000,1000,
                                 {100,100,100,100,100,100,100,100,
                                  {10,10,10,10,10,10,
                                   {undefined,undefined,undefined,

{{<<240,91,13,230,237,230,42,174,76,54,117,
                                        111,236,199,4,71>>,
                                      {message_properties,undefined,true,
                                       false},
                                      true},
                                     del,ack},

..................... deleted bunch of stuff ......................

                                   10,10},
                                  100,100},

1000,1000,1000,1000,1000,1000,1000,1000,1000,
                                 1000},
                                10000,10000,10000,10000,10000,10000,10000,
                                10000,10000}},
                              0}]},
                           #Ref<0.0.7.158837>,12066,262144,
                           #Fun<rabbit_variable_queue.2.41635915>,
                           {0,nil}},
                          {{client_msstate,msg_store_persistent,

<<158,88,38,57,48,220,55,115,72,72,33,241,89,104,
                              106,124>>,
                            {dict,0,16,16,8,80,48,

{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},
                             {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                               []}}},
                            {state,344140,

"c:/rabbitmq.hold/db/rabbit at RIOOVERLORD-1-mnesia/msg_store_persistent"},
                            rabbit_msg_store_ets_index,

"c:/rabbitmq.hold/db/rabbit at RIOOVERLORD-1-mnesia/msg_store_persistent",
                            <0.267.0>,348237,340043,352334,356431},
                           {client_msstate,msg_store_transient,

<<83,30,50,235,43,138,36,105,58,170,111,228,99,194,
                              5,152>>,
                            {dict,0,16,16,8,80,48,

{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},
                             {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                               []}}},
                            {state,323655,

"c:/rabbitmq.hold/db/rabbit at RIOOVERLORD-1-mnesia/msg_store_transient"},
                            rabbit_msg_store_ets_index,

"c:/rabbitmq.hold/db/rabbit at RIOOVERLORD-1-mnesia/msg_store_transient",
                            <0.262.0>,327752,319551,331849,335946}},

true,0,#Fun<rabbit_amqqueue_process.5.77104289>,0,0,
                          infinity,0,0,0,95,95,
                          {rates,
                           {{1353,430160,19630},155},
                           {{1353,430160,19630},155},
                           32.34796456653727,32.34796456653727,
                           {1353,430165,27630}},
                          {0,nil},
                          {0,nil},
                          {0,nil},
                          {0,nil},
                          95,95,
                          {rates,
                           {{1353,430160,19630},155},
                           {{1353,430160,19630},155},
                           32.34796456653727,32.34796456653727,
                           {1353,430165,27630}}},
                         {[{<2756.5629.0>,
                            {consumer,<<"amq.ctag-ZHZP5Ybp_xZxsi5kvmuVfw">>,
                             true}}],
                          []},
                         100800000,undefined,#Ref<0.0.8.36505>,
                         #Ref<0.0.8.1338>,
                         {state,fine,5000,#Ref<0.0.8.36524>},
                         {0,nil},
                         undefined,undefined,undefined,
                         {dict,3,16,16,8,80,48,
                          {[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},
                          {{[[<2756.5690.0>|#Ref<0.0.8.1812>],
                             [<2754.15277.4>|#Ref<0.0.8.1819>]],
                            [],[],[],[],[],[],[],
                            [[<2754.15269.4>|#Ref<0.0.8.1825>]],
                            [],[],[],[],[],[],[]}}},
                         1,
                         {{0,nil},{0,nil}},
                         undefined,
                         {dict,0,16,16,8,80,48,
                          {[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},

{{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]}}},
                         undefined,undefined}

** Reason for termination == 
** {{badmatch,rabbit_mirror_queue_master},
    [{rabbit_amqqueue_process,handle_call,3,[]},
     {gen_server2,handle_msg,2,[]},
     {proc_lib,wake_up,3,[{file,"proc_lib.erl"},{line,237}]}]}

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/RabbitMQ-3-0-Policy-ha-all-delete-issue-tp23527p23530.html
Sent from the RabbitMQ mailing list archive at Nabble.com.