[rabbitmq-discuss] RabbitMQ dying during evaluation testing

Wed Apr 22 14:44:45 BST 2009

Is there a way to make them disk-only?

I tried the updated version with the persistent switch and it died after a
million messages as well, unfortunately.
*
for(int i = 0; i < LIMIT; i++) {
                String msg = createMessageText(i);
                byte[] bytes = msg.getBytes();

                channel.basicPublish(exchange, key, true, false,
MessageProperties.PERSISTENT_TEXT_PLAIN, bytes);

            }*

We get this on the Java side:

java.net.SocketException: Broken pipe
    at java.net.SocketOutputStream.socketWrite0(Native Method)
    at java.net.SocketOutputStream.socketWrite(SocketOutputStream.java:92)
    at java.net.SocketOutputStream.write(SocketOutputStream.java:136)
    at
java.io.BufferedOutputStream.flushBuffer(BufferedOutputStream.java:65)
    at java.io.BufferedOutputStream.flush(BufferedOutputStream.java:123)
    at java.io.DataOutputStream.flush(DataOutputStream.java:106)
    at
com.rabbitmq.client.impl.SocketFrameHandler.writeFrame(SocketFrameHandler.java:164)
    at
com.rabbitmq.client.impl.AMQConnection.writeFrame(AMQConnection.java:302)
    at com.rabbitmq.client.impl.AMQCommand.transmit(AMQCommand.java:197)
    at
com.rabbitmq.client.impl.AMQChannel.quiescingTransmit(AMQChannel.java:309)
    at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:285)
    at com.rabbitmq.client.impl.ChannelN.basicPublish(ChannelN.java:392)
    at test.RabbitMQProducer.main(RabbitMQProducer.java:57)
Exception in thread "main" com.rabbitmq.client.AlreadyClosedException (clean
connection shutdown; reason: Attempt to use closed channel)
    at com.rabbitmq.client.impl.AMQChannel.ensureIsOpen(AMQChannel.java:189)
    at
com.rabbitmq.client.impl.AMQChannel.processShutdownSignal(AMQChannel.java:257)
    at
com.rabbitmq.client.impl.ChannelN.processShutdownSignal(ChannelN.java:164)
    at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:337)
    at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:291)
    at com.rabbitmq.client.impl.ChannelN.close(ChannelN.java:285)
    at test.RabbitMQProducer.main(RabbitMQProducer.java:73)

and {badrpc,nodedown} when querying for status.

Jacek

On Wed, Apr 22, 2009 at 9:40 AM, Matthias Radestock <matthias at lshift.net>wrote:

> Jacek,
>
> Jacek Furmankiewicz wrote:
>
>> Ah, I missed that. I guess that relates to this part of the docs?
>>
>
> Yes, but if your messages don't fit into memory when not marked as
> persistent then they sure won't fit when they are - as Alexis said,
> persistent messages are kept in *both* memory and disk.
>
>
> Matthias.
>
-------------- next part --------------
An HTML attachment was scrubbed...
URL: http://lists.rabbitmq.com/pipermail/rabbitmq-discuss/attachments/20090422/bb4a300e/attachment.htm 