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

[RishiDev]

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