[rabbitmq-discuss] Erlang Client - Unable to Subscribe with basic.consume

[Schlomer, Loren]

I am trying to subscribe a queue to a Pid using:

amqp_channel:call(Channel, #'basic.consume'{queue=QueueName}, Pid)

and using all other default settings in the #'basic.consume' record.  I 
get the following exception stack and have been unable to discover why.  
Any help would be greatly appreciated!


=ERROR REPORT==== 8-Jan-2010::13:52:43 ===
** Generic server <0.44.0> terminating
** Last message in was {call,
                           {'basic.consume',1,
                               <<"amq.gen-JKETIEiVgO9bzH5ZKfghkA==">>,<<>>,
                               false,false,false,false},
                           <0.47.0>}
** When Server state == {c_state,1,<0.37.0>,<0.45.0>,<0.46.0>,network,
                            {[],[]},
                            {[],[]},
                            {dict,0,16,16,8,80,48,
                                
{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                 []},
                                {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                  [],[]}}},
                            false,none,false,none,
                            {dict,0,16,16,8,80,48,
                                
{[],[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                 []},
                                {{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                  [],[]}}}}
** Reason for termination ==
** {function_clause,[{amqp_channel,build_content,[<0.47.0>]},
                     {amqp_channel,handle_call,3},
                     {gen_server,handle_msg,5},
                     {proc_lib,init_p_do_apply,3}]}

=ERROR REPORT==== 8-Jan-2010::13:52:43 ===
Connection (<0.37.0>) closing: channel (<0.44.0>) died. Reason: 
{function_clause,
                                                                 
[{amqp_channel,
                                                                   
build_content,
                                                                   
[<0.47.0>]},
                                                                  
{amqp_channel,
                                                                   
handle_call,
                                                                   3},
                                                                  
{gen_server,
                                                                   
handle_msg,
                                                                   5},
                                                                  {proc_lib,
                                                                   
init_p_do_apply,
                                                                   3}]}
** exception exit: 
{{function_clause,[{amqp_channel,build_content,[<0.47.0>]},
                                      {amqp_channel,handle_call,3},
                                      {gen_server,handle_msg,5},
                                      {proc_lib,init_p_do_apply,3}]},
                    {gen_server,call,
                                [<0.44.0>,
                                 {call,{'basic.consume',1,
                                                        
<<"amq.gen-JKETIEiVgO9bzH5ZKfghkA==">>,<<>>,false,false,
                                                        false,false},
                                       <0.47.0>},
                                 infinity]}}
     in function  gen_server:call/3
     in call from rabbitmq_test:consume/0
2>
=ERROR REPORT==== 8-Jan-2010::13:52:43 ===
** Generic server <0.37.0> terminating
** Last message in was {'$gen_cast',{method,{'connection.close_ok'},none}}
** When Server state == {nc_state,
                            
{amqp_params,<<"guest">>,<<"guest">>,<<"/test">>,
                                "localhost",5672,0,0,0,none},
                            #Port<0.530>,<0.42.0>,<0.41.0>,<0.40.0>,0,0,
                            {nc_closing,internal_error,
                                {'connection.close',541,<<>>,0,0},
                                none,wait_close_ok},
                            {{0,nil},
                             {dict,0,16,16,8,80,48,
                                 {[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                  [],[]},
                                 
{{[],[],[],[],[],[],[],[],[],[],[],[],[],[],
                                   [],[]}}}}}
** Reason for termination ==
** {internal_error,541,<<>>}