Open MPI logo

Open MPI Development Mailing List Archives

  |   Home   |   Support   |   FAQ   |   all Development mailing list

Subject: Re: [OMPI devel] Client connection lost
From: Jeff Squyres (jsquyres_at_[hidden])
Date: 2008-06-27 06:37:25


I think you're posting to the wrong list -- this list is for Open MPI
support. I'm not quite sure what OpenAMQ is, but it seems to be an
entirely different application.

You might want to google around to find support for OpenAMQ. Good luck.

On Jun 26, 2008, at 10:52 PM, Caciano Machado wrote:

> Hi,
>
> After publishing and consuming some messages (greater than 128KB)
> suddenly my application loses its connections to the server and prints
> the following log. If I use only smaller messages then nothing wrong
> happens.
>
> 18:14:44: E: Socket error: Bad address, connection to server lost
> (10.135.250.16:5672)
>
> the server prints this one:
>
> 2008-06-26 18:14:44: E: Socket closing: End of file found, connection
> to client lost (10.135.250.16:34733, OpenAMQ Kernel Client, 1.2d0, 0)
>
> Any ideas of what could be wrong?
>
> ####################################################################
>
> Here is a "resume" of my configuration:
>
> /* QUEUE DECLARE */
> amq_client_session_queue_declare (
> mom_endpoint_addr.sess, /* session */
> 0, /* ticket */
> mom_addr.queue, /* queue name */
> FALSE, /* passive */
> FALSE, /* durable */
> TRUE, /* exclusive */
> TRUE, /* auto-delete */
> NULL); /* arguments */
>
> /* QUEUE BIND */
> amq_client_session_queue_bind (
> mom_endpoint_addr.sess, /* session */
> 0, /* ticket */
> mom_addr.queue, /* queue */
> "amq.direct", /* exchange */
> mom_addr.key, /* routing-key */
> NULL); /* arguments */
>
> /* QUEUE CONSUME */
> amq_client_session_basic_consume (
> mom_endpoint_addr.sess, /* session */
> 0, /* ticket */
> mom_addr.queue, /* queue */
> NULL, /* consumer-tag */
> TRUE, /* no-local */
> TRUE, /* no-ack */
> TRUE, /* exclusive */
> NULL); /* arguments */
> ...
> /* RECEIVE MESSAGES */
> amq_client_session_wait(mom_endpoint_addr.sess, 30000);
> amq_content_basic_get_body(content_recv, (byte*) buf, length));
> amq_content_basic_unlink (&content_recv);
> ...
> /* PUBLISH MESSAGE*/
> mom_return = amq_client_session_basic_publish (
> mom_endpoint->mom_peer_addr.sess, /* session */
> content, /* content to send */
> 0, /* ticket */
> "amq.direct",
> mom_endpoint->mom_peer->key, /* routing-key */
> FALSE, /* mandatory */
> FALSE); /* immediate */
>
> ####################################################################
>
> And here is a trace log of the server:
>
> cmachado_at_xiru-6:~$ amq_server --trace 1
> OpenAMQ/1.2d0
> Production release
>
> Copyright (c) 2007-2008 iMatix Corporation
> This is free software; see the source for copying conditions. There
> is NO
> warranty; not even for MERCHANTABILITY or FITNESS FOR A PARTICULAR
> PURPOSE.
>
> 2008-06-26 21:29:10: W: security warning - logins use default
> passwords
> 2008-06-26 21:29:10: I: hostname is xiru-6 (10.135.250.16)
> 2008-06-26 21:29:10: I: listening on port 5672, all network interfaces
> 2008-06-26 21:29:10: I: no failover defined, READY as stand-alone
> 2008-06-26 21:29:11: I: server ready for incoming AMQ connections
> 2008-06-26 21:29:21: I: send connection.start: version_major=0
> version_minor=9 server_properties=184B mechanisms=5B locales=5B
> 2008-06-26 21:29:21: I: recv connection.start-ok:
> client_properties=184B mechanism="PLAIN" response=12B locale="en_US"
> 2008-06-26 21:29:21: I: send connection.tune: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
> capabilities="" insist=0
> 2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
> 2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
> 2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
> 2008-06-26 21:29:21: I: recv queue.declare: ticket=0 queue="0"
> passive=0 durable=0 exclusive=1 auto_delete=1 nowait=0 arguments=0B
> 2008-06-26 21:29:21: I: send queue.declare-ok: queue="0"
> message_count=0 consumer_count=0
> 2008-06-26 21:29:21: I: recv queue.bind: ticket=0 queue="0"
> exchange="amq.direct" routing_key="0" nowait=0 arguments=0B
> 2008-06-26 21:29:21: I: send queue.bind-ok:
> 2008-06-26 21:29:21: I: recv basic.consume: ticket=0 queue="0"
> consumer_tag="" no_local=1 no_ack=1 exclusive=1 nowait=0 arguments=0B
> 2008-06-26 21:29:21: I: send basic.consume-ok: consumer_tag="0"
> 2008-06-26 21:29:21: I: send connection.start: version_major=0
> version_minor=9 server_properties=184B mechanisms=5B locales=5B
> 2008-06-26 21:29:21: I: recv connection.start-ok:
> client_properties=184B mechanism="PLAIN" response=12B locale="en_US"
> 2008-06-26 21:29:21: I: send connection.tune: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
> capabilities="" insist=0
> 2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
> 2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
> 2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
> 2008-06-26 21:29:21: I: recv queue.declare: ticket=0 queue="1"
> passive=0 durable=0 exclusive=1 auto_delete=1 nowait=0 arguments=0B
> 2008-06-26 21:29:21: I: send queue.declare-ok: queue="1"
> message_count=0 consumer_count=0
> 2008-06-26 21:29:21: I: recv queue.bind: ticket=0 queue="1"
> exchange="amq.direct" routing_key="1" nowait=0 arguments=0B
> 2008-06-26 21:29:21: I: send queue.bind-ok:
> 2008-06-26 21:29:21: I: recv basic.consume: ticket=0 queue="1"
> consumer_tag="" no_local=1 no_ack=1 exclusive=1 nowait=0 arguments=0B
> 2008-06-26 21:29:21: I: send basic.consume-ok: consumer_tag="0"
> 2008-06-26 21:29:21: I: send connection.start: version_major=0
> version_minor=9 server_properties=184B mechanisms=5B locales=5B
> 2008-06-26 21:29:21: I: send connection.start: version_major=0
> version_minor=9 server_properties=184B mechanisms=5B locales=5B
> 2008-06-26 21:29:21: I: recv connection.start-ok:
> client_properties=184B mechanism="PLAIN" response=12B
> locale="en_US"2008-06-26 21:29:21: I: recv connection.start-ok:
> client_properties=184B mechanism="PLAIN" response=12B locale="en_US"
> 2008-06-26 21:29:21: I: send connection.tune: channel_max=1
> frame_max=32768 heartbeat=2
>
> 2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
> capabilities="" insist=0
> 2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
> 2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
> 2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
> 2008-06-26 21:29:21: I: send connection.tune: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
> capabilities="" insist=0
> 2008-06-26 21:29:21: I: send connection.start: version_major=0
> version_minor=9 server_properties=184B mechanisms=5B locales=5B
> 2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
> 2008-06-26 21:29:21: I: recv connection.start-ok:
> client_properties=184B mechanism="PLAIN" response=12B locale="en_US"
> 2008-06-26 21:29:21: I: send connection.tune: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
> capabilities="" insist=0
> 2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
> 2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
> 2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
> 2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
> 2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
> 2008-06-26 21:29:21: I: send connection.start: version_major=0
> version_minor=9 server_properties=184B mechanisms=5B locales=5B
> 2008-06-26 21:29:21: I: recv connection.start-ok:
> client_properties=184B mechanism="PLAIN" response=12B locale="en_US"
> 2008-06-26 21:29:21: I: send connection.tune: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.tune-ok: channel_max=1
> frame_max=32768 heartbeat=2
> 2008-06-26 21:29:21: I: recv connection.open: virtual_host="/"
> capabilities="" insist=0
> 2008-06-26 21:29:21: I: send connection.open-ok: known_hosts=""
> 2008-06-26 21:29:21: I: recv channel.open: out_of_band=""
> 2008-06-26 21:29:21: I: send channel.open-ok: channel_id=4B
> 2008-06-26 21:29:21: I: recv basic.publish: ticket=0
> exchange="amq.direct" routing_key="1" mandatory=0 immediate=0
> 2008-06-26 21:29:21: I: send basic.deliver: consumer_tag="0"
> delivery_tag=0 redelivered=0 exchange="amq.direct" routing_key="1"
> 2008-06-26 21:29:21: I: recv basic.publish: ticket=0
> exchange="amq.direct" routing_key="0" mandatory=0 immediate=0
> 2008-06-26 21:29:21: E: Socket closing: End of file found, connection
> to client lost (10.135.250.17:51695, OpenAMQ Kernel Client, 1.2d0, 0)
>
> ####################################################################
>
> Regards,
> Caciano Machado
> _______________________________________________
> devel mailing list
> devel_at_[hidden]
> http://www.open-mpi.org/mailman/listinfo.cgi/devel

-- 
Jeff Squyres
Cisco Systems