[rabbitmq-discuss] Unable to start direct connection using Erlang client

Fri Mar 29 21:07:50 GMT 2013

Hi All,

I really need you help since
I spend few days trying to make direct connection to RabbitMQ using Erlang 
client (both located on same host):

{ok, Connection} =
>         amqp_connection:start(#amqp_params_direct{ node = 
> <<"kiosk at localhost">>}),

Same connection but  #amqp_params_network works without any problem.
I'm dumping cookie before this call (using get_cookie()) and it'ss same as 
/var/lib/rabbitmq/.erlang.cookie  and /root/.erlang.cookie

RabbitMQ version: 2.7.1
Erlang AMQP client lib version: 2.7.1
Erlang version:  R14B04

rabbitmq-server output:
---------
/usr/lib/rabbitmq/bin/rabbitmq-server
Activating RabbitMQ plugins ...
10 plugins activated:
* amqp_client-0.0.0
* mochiweb-1.3-rmq0.0.0-git
* rabbitmq_consistent_hash_exchange-0.0.0
* rabbitmq_federation-0.0.0
* rabbitmq_management-0.0.0
* rabbitmq_management_agent-0.0.0
* rabbitmq_management_visualiser-0.0.0
* rabbitmq_mochiweb-0.0.0
* rabbitmq_tracing-0.0.0
* webmachine-1.7.0-rmq0.0.0-hg

node with name "kiosk" already running on "localhost"
diagnostics:
- nodes and their ports on localhost: [{kiosk,44319},
                                       {rabbitmqprelaunch671,54355}]
- current node: rabbitmqprelaunch671 at localhost
- current node home dir: /root
- current node cookie hash: UuV+hP3qioICevzwrp5uuw==

---------

Runtime error log:
-----------------------
=ERROR REPORT==== 29-Mar-2013::21:03:24 ===
** Generic server <0.46.0> terminating
** Last message in was connect
** When Server state == {state,amqp_direct_connection,
                            {state,undefined,undefined,undefined,undefined,
                                undefined,undefined,undefined},
                            <0.45.0>,undefined,
                            {amqp_params_direct,<<"guest">>,<<"/">>,
                                <<"kiosk at localhost">>,none,[]},
                            undefined,undefined,
                            #Fun<amqp_connection_sup.1.36702488>,
                            #Fun<amqp_connection_sup.2.54430129>,false}
** Reason for termination ==
** {{function_clause,[{gen,call,
                           [{rex,<<"kiosk at localhost">>},
                            '$gen_call',
                            {call,rabbit_direct,connect,
                                  [<<"guest">>,<<"/">>,
                                   rabbit_framing_amqp_0_9_1,<0.46.0>,
                                   [{pid,<0.46.0>},
                                    {protocol,{'Direct',{0,9,1}}},
                                    {address,unknown},
                                    {port,unknown},
                                    {name,<<"<t1 at localhost.2.46.0>">>},
                                    {peer_address,unknown},
                                    {peer_port,unknown},
                                    {user,<<"guest">>},
                                    {vhost,<<"/">>},
                                    {client_properties,[]},
                                    {type,direct}]],
                                  <0.42.0>},
                            infinity]},
                      {gen_server,call,3},
                      {rpc,do_call,3},
                      {amqp_direct_connection,connect,4},
                      {amqp_gen_connection,handle_call,3},
                      {gen_server,handle_msg,5},
                      {proc_lib,init_p_do_apply,3}]},
    {gen_server,call,
                [{rex,<<"kiosk at localhost">>},
                 {call,rabbit_direct,connect,
                       [<<"guest">>,<<"/">>,rabbit_framing_amqp_0_9_1,
                        <0.46.0>,
                        [{pid,<0.46.0>},
                         {protocol,{'Direct',{0,9,1}}},
                         {address,unknown},
                         {port,unknown},
                         {name,<<"<t1 at localhost.2.46.0>">>},
                         {peer_address,unknown},
                         {peer_port,unknown},
                         {user,<<"guest">>},
                         {vhost,<<"/">>},
                         {client_properties,[]},
                         {type,direct}]],
                       <0.42.0>},
                 infinity]}}
escript: exception exit: {{{function_clause,
                      [{gen,call,
                           [{rex,<<"kiosk at localhost">>},
                            '$gen_call',
                            {call,rabbit_direct,connect,
                                [<<"guest">>,<<"/">>,
                                 rabbit_framing_amqp_0_9_1,<0.46.0>,
                                 [{pid,<0.46.0>},
                                  {protocol,{'Direct',{0,9,1}}},
                                  {address,unknown},
                                  {port,unknown},
                                  {name,<<"<t1 at localhost.2.46.0>">>},
                                  {peer_address,unknown},
                                  {peer_port,unknown},
                                  {user,<<"guest">>},
                                  {vhost,<<"/">>},
                                  {client_properties,[]},
                                  {type,direct}]],
                                <0.42.0>},
                            infinity]},
                       {gen_server,call,3},
                       {rpc,do_call,3},
                       {amqp_direct_connection,connect,4},
                       {amqp_gen_connection,handle_call,3},
                       {gen_server,handle_msg,5},
                       {proc_lib,init_p_do_apply,3}]},
                  {gen_server,call,
                      [{rex,<<"kiosk at localhost">>},
                       {call,rabbit_direct,connect,
                           [<<"guest">>,<<"/">>,rabbit_framing_amqp_0_9_1,
                            <0.46.0>,
                            [{pid,<0.46.0>},
                             {protocol,{'Direct',{0,9,1}}},
                             {address,unknown},
                             {port,unknown},
                             {name,<<"<t1 at localhost.2.46.0>">>},
                             {peer_address,unknown},
                             {peer_port,unknown},
                             {user,<<"guest">>},
                             {vhost,<<"/">>},
                             {client_properties,[]},
                             {type,direct}]],
                           <0.42.0>},
                       infinity]}},
                 {gen_server,call,[<0.46.0>,connect,infinity]}}
  in function  gen_server:call/3
  in call from erl_eval:do_apply/5
  in call from erl_eval:expr/5
  in call from escript:eval_exprs/5
  in call from erl_eval:local_func/5
  in call from escript:interpret/4
  in call from escript:start/1
  in call from init:start_it/1
-----------------------

Thank you in advance for any ideas,

Best,
Alexander Reshniuk
-------------- next part --------------
An HTML attachment was scrubbed...
URL: <http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20130329/4a51e2dd/attachment.htm>