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

shared durable subscriber: new connection with different selector also changes maxConsumers

    XMLWordPrintable

Details

    • Hide

      1. Create address

      $ curl --header "Origin: http://localhost" --user admin:admin "http://127.0.0.1:8161/console/jolokia/exec/org.apache.activemq.artemis:broker=%220.0.0.0%22/createAddress(java.lang.String,java.lang.String)/FOO/MULTICAST"
      

      2. Run reproducer

      //configure home directory for AMQ distribution in pom.xml

      mvn -PnoServer clean verify
      

      //producer will pause after creating first subscriber

      3. Check maxConsumers

      $ curl --header "Origin: http://localhost" --user admin:admin "http://localhost:8161/console/jolokia/read/org.apache.activemq.artemis:broker=%220.0.0.0%22,component=addresses,address=%22FOO%22,subcomponent=queues,routing-type=%22multicast%22,queue=%22FOO:global%22/MaxConsumers"
      

      maxConsumers == -1

      4. Continue reproducer (hit enter)

      5. Check maxConsumers again

      $ curl --header "Origin: http://localhost" --user admin:admin "http://localhost:8161/console/jolokia/read/org.apache.activemq.artemis:broker=%220.0.0.0%22,component=addresses,address=%22FOO%22,subcomponent=queues,routing-type=%22multicast%22,queue=%22FOO:global%22/MaxConsumers"
      

      maxConsumers == 1

      Show
      1. Create address $ curl --header "Origin: http: //localhost" --user admin:admin "http://127.0.0.1:8161/console/jolokia/exec/org.apache.activemq.artemis:broker=%220.0.0.0%22/createAddress(java.lang. String ,java.lang. String )/FOO/MULTICAST" 2. Run reproducer //configure home directory for AMQ distribution in pom.xml mvn -PnoServer clean verify //producer will pause after creating first subscriber 3. Check maxConsumers $ curl --header "Origin: http: //localhost" --user admin:admin "http://localhost:8161/console/jolokia/read/org.apache.activemq.artemis:broker=%220.0.0.0%22,component=addresses,address=%22FOO%22,subcomponent=queues,routing-type=%22multicast%22,queue=%22FOO:global%22/MaxConsumers" maxConsumers == -1 4. Continue reproducer (hit enter) 5. Check maxConsumers again $ curl --header "Origin: http: //localhost" --user admin:admin "http://localhost:8161/console/jolokia/read/org.apache.activemq.artemis:broker=%220.0.0.0%22,component=addresses,address=%22FOO%22,subcomponent=queues,routing-type=%22multicast%22,queue=%22FOO:global%22/MaxConsumers" maxConsumers == 1

    Description

      See reproducer attached to this ticket - when a subscriber is created the maxConsumers is '-1'. The same subscriber is re-created with a different selector and the maxConsumers is '1'. The expected outcome is maxConsumers '-1' in both cases.

      If the selector does not change, the maxConsumers remains at '-1'.

      Attachments

        Issue Links

          Activity

            People

              ataylor@redhat.com Andy Taylor
              rhn-support-shiggs Stephen Higgs
              Oleg Sushchenko Oleg Sushchenko
              Votes:
              0 Vote for this issue
              Watchers:
              1 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: