[rabbitmq-discuss] errors in riak_queue impl

[Jonathan Brisbin]

I think I might be returning something incorrectly from fetch. Now I'm getting the following:

=ERROR REPORT==== 9-Feb-2011::10:40:38 ===
connection <0.209.0> (running), channel 1 - error:
shutdown

=WARNING REPORT==== 9-Feb-2011::10:40:38 ===
Non-AMQP exit reason 'shutdown'

I can't find where this is coming from.

I'm returning from fetch the following:

=INFO REPORT==== 9-Feb-2011::10:40:38 ===
fetch result: {{basic_message,
                   {resource,<<"/">>,exchange,<<"test">>},
                   <<>>,
                   {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",87,104,104,72,90,43,84,
                                   65,99,88,116,78,74,86,120,50,101,121,82,86,
                                   103,103,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}">>]},
                   <<90,24,71,103,228,192,113,123,77,37,92,118,123,36,85,130>>,
                   undefined},
               true,"0",0}

Not sure what I'm missing, though.

Any ideas?

Thanks!

jb


On Feb 8, 2011, at 11:14 AM, Matthew Sackman wrote:

> On Tue, Feb 08, 2011 at 03:47:00PM +0000, Robert Raschke wrote:
>>> =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}]}'
>>> 
>>> 
>> Shot in the dark:
>> 
>> Looks like the 'resource' record doesn't match up somewhere; maybe it's got
>> different number of fields in different locations.
> 
> Probably something like you're using an #amqqueue where you should just
> be using a #resource, or you're using a binary where you should be using
> a #resource... something like that.
> 
> Matthew
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss


Thanks!

Jon Brisbin

Twitter: @j_brisbin
Skype: jon.brisbin