[rabbitmq-discuss] Error while connect to rabbitmq using rabbitmq-erlang-client library

[Alexandru Scvorţov]

Glad you solved the problem.

Quick question: what version of RabbitMQ were you using?

Cheers,
Alex

On Fri, Aug 05, 2011 at 08:48:08PM +0800, Fisher Yu wrote:
> Hi,
> 
>    This problem is solved. It is because the rabbitmq version is too old.
> After i updated to last version, it works. Thanks for your help.
> 
> Fisher
> 
> 2011/8/4 Alexandru Scvorţov <alexandru at rabbitmq.com>
> 
> > Also, could you please post the output of:
> > $ ulimit -a
> >
> > Alex
> >
> > On Wed, Aug 03, 2011 at 11:31:27AM +0800, Fisher Yu wrote:
> >  > 2011/8/2 Alexandru Scvorţov <alexandru at rabbitmq.com>
> > >
> > > > Hi,
> > > >
> > > > > ** Reason for termination ==
> > > > > ** {{badmatch,{error,enomem}},
> > > > >     [{amqp_main_reader,handle_inet_async,2},
> > > > >      {gen_server,handle_msg,5},
> > > > >      {proc_lib,init_p_do_apply,3}]}
> > > >
> > > > Strictly speaking, that means you've run out of memory.  Not sure how
> > > > that could happen, though.
> > > >
> > > > There's an error in your example:
> > > >
> > > > >         Get = #'basic.get'{queue = Queue},
> > > >
> > > > should be
> > > >
> > > > >         Get = #'basic.get'{queue = list_to_binary(Queue)},
> > > >
> > > > Actually, you'd probably be better off converting Queue to a binary
> > from
> > > > the start.
> > > >
> > >
> > > Changed this, thanks.
> > >
> > >
> > > >
> > > > Still, the failure is during the initial handshake, so that can't be
> > the
> > > > cause.
> > > >
> > > > Have a look in the server logs: is there a matching error?  Is there
> > any
> > > > mention
> > > > of the memory alarms being set off?
> > > >
> > >
> > > There is nothing happening in the server logs, at least nothing being
> > > raised.  There is 24G RAM in here, with about 4G active and 11G free at
> > the
> > > time of testing.
> > >
> > >
> > >
> > > >
> > > > What OS are you using?  What version of Erlang?  Is there anything
> > > > special about the system's configuration?  Is it under heavy load?
> > > >
> > >
> > >
> > > The distribution is Ubuntu 10.04,
> > > uname -a
> > > Linux fs21 2.6.32-31-generic #61-Ubuntu SMP Fri Apr 8 18:25:51 UTC 2011
> > > x86_64 GNU/Linux
> > >
> > > Erlang version
> > > Erlang R14B03 (erts-5.8.4) [source] [64-bit] [smp:24:24] [rq:24]
> > > [async-threads:0] [kernel-poll:false]
> > >
> > > This machine is almost completely idle at the moment as it's a
> > development
> > > server.  There is nothing special for the configuration.
> > >
> > >
> > > >
> > > > >   I kept get error message while connect to rabbitmq server using
> > > > > rabbitmq-erlang-client library. Anyone can help, thanks.
> > > >
> > > > Does this mean you *always* get this error?  Or only occasionally?
> > > >
> > >
> > > Every time the test case is run, this error is produced.
> > >
> > >
> > > >
> > > > Cheers,
> > > > Alex
> > > >
> > > > On Tue, Aug 02, 2011 at 09:43:46PM +0800, Fisher Yu wrote:
> > > > > Hi
> > > > >
> > > > >   I kept get error message while connect to rabbitmq server using
> > > > > rabbitmq-erlang-client library. Anyone can help, thanks.
> > > > >
> > > > > Erlang R14B03 (erts-5.8.4) [source] [64-bit] [smp:24:24] [rq:24]
> > > > > [async-threads:0] [kernel-poll:false]
> > > > > Eshell V5.8.4  (abort with ^G)
> > > > > 1> test:start().
> > > > > =ERROR REPORT==== 2-Aug-2011::08:40:18 ===
> > > > > ** Generic server <0.46.0> terminating
> > > > > ** Last message in was
> > > > > {inet_async,#Port<0.1109>,1,{ok,<<65,77,81,80,1,1,8>>}}
> > > > > ** When Server state == {state,#Port<0.1109>,<0.39.0>,<0.41.0>,
> > > > >                                {method,rabbit_framing_amqp_0_9_1},
> > > > >                                none}
> > > > > ** Reason for termination ==
> > > > > ** {{badmatch,{error,enomem}},
> > > > >     [{amqp_main_reader,handle_inet_async,2},
> > > > >      {gen_server,handle_msg,5},
> > > > >      {proc_lib,init_p_do_apply,3}]}
> > > > >
> > > > >
> > > > >
> > > > > %%test.erl
> > > > >
> > > > > -module(test).
> > > > > -include_lib("amqp_client/include/amqp_client.hrl").
> > > > > -compile(export_all).
> > > > > start() ->
> > > > >         {ok, Connection} =
> > > > > amqp_connection:start(#amqp_params_network{username= <<"myuser">>,
> > > > password=
> > > > > <<"mypassword">>}),
> > > > >         {ok, Channel} = amqp_connection:open_channel(Connection),
> > > > >         Queue = "my_queue",
> > > > >         Declare = #'queue.declare'{queue = list_to_binary(Queue),
> > > > > durable=true},
> > > > >         #'queue.declare_ok'{} = amqp_channel:call(Channel, Declare),
> > > > >         Get = #'basic.get'{queue = Queue},
> > > > >         {#'basic.get_ok'{delivery_tag = Tag}, Content}
> > > > >                        = amqp_channel:call(Channel, Get),
> > > > >         io:format("received message ~p", [Content]),
> > > > >         %% Close the channel
> > > > >         amqp_channel:close(Channel),
> > > > >         %% Close the connection
> > > > >         amqp_connection:close(Connection),
> > > > >         ok.
> > > >
> > > > > _______________________________________________
> > > > > rabbitmq-discuss mailing list
> > > > > rabbitmq-discuss at lists.rabbitmq.com
> > > > > https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
> > > >
> > > >
> >