[rabbitmq-discuss] errors in riak_queue impl

[Jonathan Brisbin]

I'm getting some errors while playing with this rabbit_riak_queue implementation I'm working on. It's happening when I get notification of a delivered message. Any idea on what's going on here?

=ERROR REPORT==== 8-Feb-2011::10:27:55 ===
** Generic server <0.253.0> terminating
** Last message in was {'$gen_cast',
                        {deliver,<<"amq.ctag-j1c04J2xVhlCLHJrDTIwaA==">>,
                         true,
                         {{resource,<<"/">>,queue,<<"test">>},
                          <0.208.0>,"2",true,
                          {basic_message,undefined,undefined,
                           {content,60,
                            {'P_basic',"application/json",undefined,
                             {dict,5,16,16,8,80,48,
                              {[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                               []},
                              {{[],
                                [["X-Riak-Meta-Bar",98,97,122]],
                                [],[],[],
                                [["X-Riak-Meta-Guid",49,112,47,67,107,71,120,
                                  100,88,97,120,112,114,119,119,116,115,70,
                                  115,90,43,65,61,61]],
                                [],[],[],
                                [["X-Riak-Meta-Queue",116,101,115,116]],
                                [],[],
                                [["X-Riak-Meta-Foo",55]],
                                [],[],
                                [["X-Riak-Meta-Classid",54,48]]}}},
                             undefined,undefined,undefined,undefined,
                             undefined,undefined,undefined,undefined,
                             undefined,undefined,undefined},
                            undefined,undefined,
                            [<<"{\"test\":\"value\", \"int\": 14}">>]},
                           <<214,159,194,144,108,93,93,172,105,175,12,45,176,
                             91,25,248>>,
                           undefined}}}}
** When Server state == {ch,running,1,<0.250.0>,<0.252.0>,undefined,
                         #Fun<rabbit_channel_sup.0.123274458>,none,
                         {set,0,16,16,8,80,48,
                          {[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},
                          {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]}}},
                         1,
                         {[],[]},
                         {[],[]},
                         {user,<<"guest">>,true,rabbit_auth_backend_internal,
                          {internal_user,<<"guest">>,
                           <<155,99,204,87,188,155,243,157,145,163,38,225,4,
                             178,160,143,117,202,5,215>>,
                           true}},
                         <<"/">>,<<"test">>,
                         {dict,1,16,16,8,80,48,
                          {[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},
                          {{[],[],[],[],[],[],[],[],[],
                            [[<<"amq.ctag-j1c04J2xVhlCLHJrDTIwaA==">>|
                              {resource,<<"/">>,queue,<<"test">>}]],
                            [],[],[],[],[],[]}}},
                         {dict,0,16,16,8,80,48,
                          {[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]},
                          {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],[]}}},
                         <0.248.0>,
                         {state,none,undefined},
                         false,1,
                         {0,nil},
                         []}
** Reason for termination == 
** {{badrecord,resource},
    [{rabbit_channel,handle_cast,2},
     {gen_server2,handle_msg,2},
     {proc_lib,init_p_do_apply,3}]}

=ERROR REPORT==== 8-Feb-2011::10:27:55 ===
connection <0.250.0> (running), channel 1 - error:
{{badrecord,resource},
 [{rabbit_channel,handle_cast,2},
  {gen_server2,handle_msg,2},
  {proc_lib,init_p_do_apply,3}]}

=WARNING REPORT==== 8-Feb-2011::10:27:55 ===
Non-AMQP exit reason '{{badrecord,resource},
                       [{rabbit_channel,handle_cast,2},
                        {gen_server2,handle_msg,2},
                        {proc_lib,init_p_do_apply,3}]}'



Thanks!

Jon Brisbin

Twitter: @j_brisbin
Skype: jon.brisbin