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

Durable subscriber raised javax.jms.JMSException Maximum Consumer Limit Reached on Queue

XMLWordPrintable

    • Icon: Bug Bug
    • Resolution: Done
    • Icon: Major Major
    • AMQ 7.1.0.CR2
    • AMQ 7.1.0.GA
    • None
    • Hide
      1. Download broker and create default instance
      2. git clone https://github.com/kornys/DurableSubscriptionTest.git
      3. cd DurableSubscriptionTest
      4. mvn -Dtest=topictests.TopicDurableTestst#testMessageDurableSubscription test
      Show
      Download broker and create default instance git clone https://github.com/kornys/DurableSubscriptionTest.git cd DurableSubscriptionTest mvn -Dtest=topictests.TopicDurableTestst#testMessageDurableSubscription test

      When I close durable subscriber from topic and try to subscribe it again, exception is raised.

      javax.jms.JMSException: AMQ219005: error creating consumer, AMQ119200: Maximum Consumer Limit Reached on Queue:(address=jmsTopic,queue=jmsTopicClient.sub1DurSub) [condition = amqp:internal-error]
              at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:164)
              at org.apache.qpid.jms.provider.amqp.AmqpSupport.convertToException(AmqpSupport.java:117)
              at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.handleClosed(AmqpResourceBuilder.java:185)
              at org.apache.qpid.jms.provider.amqp.builders.AmqpResourceBuilder.processRemoteClose(AmqpResourceBuilder.java:129)
              at org.apache.qpid.jms.provider.amqp.AmqpProvider.processUpdates(AmqpProvider.java:906)
              at org.apache.qpid.jms.provider.amqp.AmqpProvider.access$1800(AmqpProvider.java:102)
              at org.apache.qpid.jms.provider.amqp.AmqpProvider$17.run(AmqpProvider.java:792)
              at java.util.concurrent.Executors$RunnableAdapter.call(Executors.java:511)
              at java.util.concurrent.FutureTask.run(FutureTask.java:266)
              at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.access$201(ScheduledThreadPoolExecutor.java:180)
              at java.util.concurrent.ScheduledThreadPoolExecutor$ScheduledFutureTask.run(ScheduledThreadPoolExecutor.java:293)
              at java.util.concurrent.ThreadPoolExecutor.runWorker(ThreadPoolExecutor.java:1149)
              at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:624)
              at java.lang.Thread.run(Thread.java:748)
      

              csuconic@redhat.com Clebert Suconic
              dkornel@redhat.com David Kornel
              David Kornel David Kornel
              Votes:
              0 Vote for this issue
              Watchers:
              6 Start watching this issue

                Created:
                Updated:
                Resolved: