[rabbitmq-discuss] Broker stops accepting messages after 887 messages sent

[john odendahl]

Hello,
I'm running RabbitMQ on Suse linux, basically using a fresh out of box
installation running single node rabbitmq-server.
I have a java client doing a basicaPublish.

I start sending messages and on roughly the 887th message the broker stops
accepting messages.
I kill the broker (even try deleting /var/lib/rabbitmq), restart him. Same
thing, the 887th causes the broker to stop receiving messages.

I get the following stack trace on my client:

 java.io.IOException
 at com.rabbitmq.client.impl.AMQChannel.wrap(AMQChannel.java:121)
 at com.rabbitmq.client.impl.AMQConnection.start(AMQConnection.java:254)
 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:178)
 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:227)
 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:241)
 at
com.rabbitmq.client.ConnectionFactory.newConnection(ConnectionFactory.java:252)
 at
com.ericsson.monaco.servers.MonacoServer.postMessage(MonacoServer.java:309)
 at com.ericsson.monaco.util.SessionLoadTest.main(SessionLoadTest.java:33)
Caused by: com.rabbitmq.client.ShutdownSignalException: connection error;
reason: java.net.SocketException: Software caused connection abort: recv
failed
 at com.rabbitmq.client.impl.AMQConnection.shutdown(AMQConnection.java:588)
 at
com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:454)
Caused by: java.net.SocketException: Software caused connection abort: recv
failed
 at java.net.SocketInputStream.socketRead0(Native Method)
 at java.net.SocketInputStream.read(SocketInputStream.java:129)
 at java.io.BufferedInputStream.fill(BufferedInputStream.java:218)
 at java.io.BufferedInputStream.read(BufferedInputStream.java:237)
 at java.io.DataInputStream.readUnsignedByte(DataInputStream.java:271)
 at com.rabbitmq.client.impl.Frame.readFrom(Frame.java:117)
 at
com.rabbitmq.client.impl.SocketFrameHandler.readFrame(SocketFrameHandler.java:151)
 at com.rabbitmq.client.impl.AMQConnection.readFrame(AMQConnection.java:379)
 at
com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:420)

Here is the code that sends a basic json string as the message:

channel.basicPublish(
  amqpExchange,
  routingKey,
  MessageProperties.PERSISTENT_TEXT_PLAIN,
  jsonString.getBytes());


Any ideas why this might be occurring?
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20100422/8ad265e8/attachment.htm