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

[Henry Molina]

Hi John,

How many channels are you using?

# rabbitmqctl list_channels

El jue, 22-04-2010 a las 17:21 -0400, john odendahl escribió:
> 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?
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> http://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss
Henry Molina
Jefe de Proyectos de Plataforma
Empresas La Polar S.A.
Avda. Eduardo Frei Montalva No 520, Renca
Santiago - Chile
Teléfono: 383 3425
Dirección Internet: http://www.lapolar.cl

____________________________________________________________________________
La informacion  contenida en  este mensaje  y en sus documentos adjuntos, es
estrictamente  confidencial y privado para sus destinatarios. Cualquier uso,
reproduccion, divulgacion o distribucion no autorizada  de su contenido esta
estrictamente prohibida y puede ser sancionado criminalmente.
Si ha  recibido este  correo por  error,  solicitamos avisar  al remitente y
eliminarlo de su sistema. EMPRESAS LA POLAR S.A., y  sociedades relacionadas
directa o indirectamente con esta, no seran responsables del uso indebido de
este contenido o de los adjuntos al mismo.
____________________________________________________________________________