[rabbitmq-discuss] Limitations with RabbitMQ Java Client

Tue Oct 22 17:02:56 BST 2013

Hi,

I am using the RabbitMQ Java client 3.1.5 to test the performance using
MultiCastMain.java.But my RabbitMQ crashes when executing the following
scenario:
Total Time Limit: 60s
Sampling Interval: 20s
No. Of Producer(s): 1000
No. Of Consumer(s): 1000
Minimum Size of a Message: 3000 byte
Messages Auto Acknowledged while Consumption: YES
Queue Properties: '1000 Queues each assigned to one consumer; Auto
Generated; Durable; Exclusive;'
Exchange Type: 'direct'
Message Properties: Message is Persistent;

My Memory High Watermark is 4.7 GB.

Is there any benchmark on how many consumers and producers maximum i can use
with the above watermark.

i am facing this error at client end:

DefaultExceptionHandler: Consumer
com.rabbitmq.client.QueueingConsumer at e02ddd
(amq.ctag-Hk684-l36FBBCV79J4p7aw) method handleDelivery for channel
AMQChannel(amqp://rbtadmin@135.213.26.33:5672/,1) threw an exception for
channel AMQChannel(amqp://rbtadmin@135.213.26.33:5672/,1):
java.lang.OutOfMemoryError: unable to create new native thread
	at java.lang.Thread.start0(Native Method)
	at java.lang.Thread.start(Thread.java:640)
	at
java.util.concurrent.ThreadPoolExecutor.addIfUnderCorePoolSize(ThreadPoolExecutor.java:703)
	at
java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:652)
	at
com.rabbitmq.client.impl.ConsumerWorkService.addWork(ConsumerWorkService.java:62)
	at
com.rabbitmq.client.impl.ConsumerDispatcher.execute(ConsumerDispatcher.java:185)
	at
com.rabbitmq.client.impl.ConsumerDispatcher.executeUnlessShuttingDown(ConsumerDispatcher.java:180)
	at
com.rabbitmq.client.impl.ConsumerDispatcher.handleDelivery(ConsumerDispatcher.java:117)
	at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:345)
	at
com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:144)
	at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:91)
	at
com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:533)

DefaultExceptionHandler: Consumer
com.rabbitmq.client.QueueingConsumer at 144ee21
(amq.ctag-B1781nigeRKxCeCadL9f6A) method handleDelivery for channel
AMQChannel(amqp://rbtadmin@135.213.26.33:5672/,1) threw an exception for
channel AMQChannel(amqp://rbtadmin@135.213.26.33:5672/,1):
java.lang.OutOfMemoryError: unable to create new native thread
	at java.lang.Thread.start0(Native Method)
	at java.lang.Thread.start(Thread.java:640)
	at
java.util.concurrent.ThreadPoolExecutor.addIfUnderCorePoolSize(ThreadPoolExecutor.java:703)
	at
java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:652)
	at
com.rabbitmq.client.impl.ConsumerWorkService.addWork(ConsumerWorkService.java:62)
	at
com.rabbitmq.client.impl.ConsumerDispatcher.execute(ConsumerDispatcher.java:185)
	at
com.rabbitmq.client.impl.ConsumerDispatcher.executeUnlessShuttingDown(ConsumerDispatcher.java:180)
	at
com.rabbitmq.client.impl.ConsumerDispatcher.handleDelivery(ConsumerDispatcher.java:117)
	at com.rabbitmq.client.impl.ChannelN.processAsync(ChannelN.java:345)
	at
com.rabbitmq.client.impl.AMQChannel.handleCompleteInboundCommand(AMQChannel.java:144)
	at com.rabbitmq.client.impl.AMQChannel.handleFrame(AMQChannel.java:91)
	at
com.rabbitmq.client.impl.AMQConnection$MainLoop.run(AMQConnection.java:533)
Exception in thread "pool-781-thread-3" java.lang.OutOfMemoryError: unable
to create new native thread
	at java.lang.Thread.start0(Native Method)
	at java.lang.Thread.start(Thread.java:640)
	at
java.util.concurrent.ThreadPoolExecutor.addIfUnderCorePoolSize(ThreadPoolExecutor.java:703)
	at
java.util.concurrent.ThreadPoolExecutor.execute(ThreadPoolExecutor.java:652)
	at
com.rabbitmq.client.impl.ConsumerWorkService$WorkPoolRunnable.run(ConsumerWorkService.java:80)
	at
java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
	at
java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)

--
View this message in context: http://rabbitmq.1065348.n5.nabble.com/Limitations-with-RabbitMQ-Java-Client-tp30727.html
Sent from the RabbitMQ mailing list archive at Nabble.com.