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@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
de...@open-mpi.org
http://www.open-mpi.org/mailman/listinfo.cgi/devel
--
Jeff Squyres
Cisco Systems
