Loading...

XML

Word

Printable

GSS Priority:
Target Release:

AMQ 7.2.0.GA
Steps to Reproduce:

Hide

1. Create a queue with max-consumers in broker.xml
~~~~
<address name="TestQueue">
<anycast>
<queue name="TestQueue" max-consumers="1"/>
</anycast>
</address>
~~~~~~
2. Start the broker.
3. Run the attached Receiver.java. — exception will be thrown
~~~~~~~
consumer 1
javax.jms.JMSException: AMQ219005: error creating consumer, AMQ119200: Maximum Consumer Limit Reached on Queue:(address=TestQueue,queue=TestQueue) [condition = amqp:internal-error]
~~~~~~~
4. Run the Receiver.java again – consumerCount>Max consumer
5. Check the console,
~~~~~~~
Consumer count =2
Max consumers =1
~~~~~~~

Show
1. Create a queue with max-consumers in broker.xml ~~~~ <address name="TestQueue"> <anycast> <queue name="TestQueue" max-consumers="1"/> </anycast> </address> ~~~~~~ 2. Start the broker. 3. Run the attached Receiver.java. — exception will be thrown ~~~~~~~ consumer 1 javax.jms.JMSException: AMQ219005: error creating consumer, AMQ119200: Maximum Consumer Limit Reached on Queue:(address=TestQueue,queue=TestQueue) [condition = amqp:internal-error] ~~~~~~~ 4. Run the Receiver.java again – consumerCount>Max consumer 5. Check the console, ~~~~~~~ Consumer count =2 Max consumers =1 ~~~~~~~

max-consumers attribute in queue definition does not work for AMQP client.