[rabbitmq-discuss] Consumer - threw an exception for channel AMQChannel

Rob Harrop rob at rabbitmq.com
Fri Mar 11 16:30:19 GMT 2011


What heap size do you have configured for your JVM? It's is entirely 
possible that if you're using the default sizes that 16 3MB msgs will 
cause you to start hitting the OOM exception.

Regards,

Rob

On 11/03/11 16:02, RishiDev wrote:
> Hi,
>
> I have about 10K large msgs (each ~3 MB) in a queue. Started running a
> java consumer client on the queue and after receiving 16 msgs I got
> following exception. Please help resolve/understand the issue.
>
> Consumer com.rabbitmq.client.QueueingConsumer at 15b9e68 (amq.ctag-bEjkq
> +5EqqmXsp1idK9rrg==) method handleDelivery for channel
> AMQChannel(amqp://guest@localhost:5672/,1) threw an exception for
> channel AMQChannel(amqp://guest@localhost:5672/,1):
> java.lang.OutOfMemoryError
> com.rabbitmq.client.AlreadyClosedException: clean connection shutdown;
> reason: Attempt to use closed channel
> 	at com.rabbitmq.client.impl.AMQChannel.ensureIsOpen(AMQChannel.java:
> 195)
> 	at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:290)
> 	at com.rabbitmq.client.impl.AMQChannel.transmit(AMQChannel.java:284)
> 	at com.rabbitmq.client.impl.ChannelN.basicAck(ChannelN.java:669)
> 	at
> com.octanner.jmspoc.rabbitmq.RabbitMQConsumer.receiveMsgs(RabbitMQConsumer.java:
> 69)
> 	at
> com.octanner.jmspoc.rabbitmq.RabbitMQConsumer.main(RabbitMQConsumer.java:
> 77)
> Exception in thread "main"
>
> Thanks,
> Rishi
> _______________________________________________
> rabbitmq-discuss mailing list
> rabbitmq-discuss at lists.rabbitmq.com
> https://lists.rabbitmq.com/cgi-bin/mailman/listinfo/rabbitmq-discuss


More information about the rabbitmq-discuss mailing list