Uploaded image for project: 'AMQ Broker'
  1. AMQ Broker
  2. ENTMQBR-1554

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

    XMLWordPrintable

Details

    • 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 ~~~~~~~

    Description

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

      Attachments

        Issue Links

          Activity

            People

              ataylor@redhat.com Andy Taylor
              rhn-support-shsingh Shailendra Singh
              Michal Toth Michal Toth
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: