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

    • rhel7x

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