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
