[rabbitmq-discuss] BQL with 1.8.1

[Jon Brisbin]

Trying to follow the directions on installing the BQL plugin into my freshly-updated 1.8.1 broker and I get various errors like the below.

Will this work with 1.8.1?

Jon Brisbin
Portal Webmaster
NPC International, Inc.


=INFO REPORT==== 5-Aug-2010::11:25:11 ===
Limiting to approx 924 file handles

=INFO REPORT==== 5-Aug-2010::11:25:11 ===
Memory limit set to 25318MB.

=INFO REPORT==== 5-Aug-2010::11:25:11 ===
Rolling persister log to "/var/lib/rabbitmq/mnesia/rabbit at warehouse1/rabbit_persister.LOG.previous"

=INFO REPORT==== 5-Aug-2010::11:25:11 ===
started TCP Listener on 0.0.0.0:5672

=ERROR REPORT==== 5-Aug-2010::11:25:11 ===
** Generic server <0.218.0> terminating 
** Last message in was {command,{open_channel,none}}
** When Server state == {dc_state,
                            {amqp_params,<<"guest">>,<<"guest">>,<<"/">>,
                                "localhost",5672,0,0,0,none,[]},
                            false,
                            [{<<"product">>,longstr,<<"RabbitMQ">>},
                             {<<"version">>,longstr,<<"1.8.1">>},
                             {<<"platform">>,longstr,<<"Erlang/OTP">>},
                             {<<"copyright">>,longstr,
                              <<"Copyright (C) 2007-2010 LShift Ltd., Cohesive Financial Technologies LLC., and Rabbit Technologies Ltd.">>},
                             {<<"information">>,longstr,
                              <<"Licensed under the MPL.  See http://www.rabbitmq.com/">>}],
                            {{0,nil},
                             {dict,0,16,16,8,80,48,
                                 {[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                  [],[]},
                                 {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                   [],[]}}}},
                            <0.219.0>}
** Reason for termination == 
** {{badmatch,{error,{{badmatch,<0.221.0>},
                      [{amqp_channel_util,start_channel_infrastructure,3},
                       {amqp_channel,init,1},
                       {gen_server,init_it,6},
                       {proc_lib,init_p_do_apply,3}]}}},
    [{amqp_channel_util,open_channel,5},
     {amqp_direct_connection,handle_command,3},
     {gen_server,handle_msg,5},
     {proc_lib,init_p_do_apply,3}]}

=ERROR REPORT==== 5-Aug-2010::11:25:11 ===
** Generic server <0.221.0> terminating 
** Last message in was {'EXIT',<0.220.0>,
                           {{badmatch,<0.221.0>},
                            [{amqp_channel_util,start_channel_infrastructure,
                                 3},
                             {amqp_channel,init,1},
                             {gen_server,init_it,6},
                             {proc_lib,init_p_do_apply,3}]}}
** When Server state == {ch,starting,1,<0.220.0>,<0.220.0>,undefined,none,
                            {set,0,16,16,8,80,48,
                                 {[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                  [],[]},
                                 {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                   [],[]}}},
                            1,
                            {[],[]},
                            {[],[]},
                            <<"guest">>,<<"/">>,<<>>,
                            {dict,0,16,16,8,80,48,
                                  {[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                   [],[]},
                                  {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                    [],[]}}},
                            {dict,0,16,16,8,80,48,
                                  {[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                   [],[]},
                                  {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                    [],[]}}},
                            <0.219.0>,
                            {flow,true,true,none}}
** Reason for termination == 
** {{badmatch,<0.221.0>},
    [{amqp_channel_util,start_channel_infrastructure,3},
     {amqp_channel,init,1},
     {gen_server,init_it,6},
     {proc_lib,init_p_do_apply,3}]}

=INFO REPORT==== 5-Aug-2010::11:25:11 ===
    application: rabbitmq_bql
    exited: {shutdown,{rabbitmq_bql,start,[normal,[]]}}
    type: permanent

=INFO REPORT==== 5-Aug-2010::11:25:11 ===
stopped TCP Listener on 0.0.0.0:5672

=ERROR REPORT==== 5-Aug-2010::11:25:11 ===
** gen_event handler rabbit_error_logger crashed.
** Was installed in error_logger
** Last event was: {error,<0.213.0>,
                       {<0.221.0>,
                        "** Generic server ~p terminating \n** Last message in was ~p~n** When Server state == ~p~n** Reason for termination == ~n** ~p~n",
                        [<0.221.0>,
                         {'EXIT',<0.220.0>,
                             {{badmatch,<0.221.0>},
                              [{amqp_channel_util,
                                   start_channel_infrastructure,3},
                               {amqp_channel,init,1},
                               {gen_server,init_it,6},
                               {proc_lib,init_p_do_apply,3}]}},
                         {ch,starting,1,<0.220.0>,<0.220.0>,undefined,none,
                             {set,0,16,16,8,80,48,
                                 {[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                  [],[]},
                                 {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                   [],[]}}},
                             1,
                             {[],[]},
                             {[],[]},
                             <<"guest">>,<<"/">>,<<>>,
                             {dict,0,16,16,8,80,48,
                                 {[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                  [],[]},
                                 {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                   [],[]}}},
                             {dict,0,16,16,8,80,48,
                                 {[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                  [],[]},
                                 {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                   [],[]}}},
                             <0.219.0>,
                             {flow,true,true,none}},
                         {{badmatch,<0.221.0>},
                          [{amqp_channel_util,start_channel_infrastructure,3},
                           {amqp_channel,init,1},
                           {gen_server,init_it,6},
                           {proc_lib,init_p_do_apply,3}]}]}}
** When handler state == {resource,<<"/">>,exchange,<<"amq.rabbitmq.log">>}
** Reason == {badarg,[{ets,lookup,[rabbit_exchange_type_registry,topic]},
                      {rabbit_exchange_type_registry,lookup_module,1},
                      {rabbit_exchange,type_to_module,1},
                      {rabbit_exchange,publish,3},
                      {rabbit_basic,publish,1},
                      {rabbit_error_logger,publish1,4},
                      {rabbit_error_logger,handle_event,2},
                      {gen_event,server_update,4}]}