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

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

    XMLWordPrintable

Details

    • False
    • False
    • Undefined
    • 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

          is cloned by

          Bug - A problem that impairs or prevents the functions of the product. ENTMQBR-5357 [LTS] shared durable subscriber: new connection with different selector also changes maxConsumers

          • Major - To be worked after higher priority work items are addressed. When the severity is high and the effort to change it is low to moderate, this term is chosen. Issues in this category likely have an existing workaround but implementation or execution may be non-trivial.
          • Closed

          Bug - A problem that impairs or prevents the functions of the product. ENTMQBR-5571 shared durable subscriber: new connection with different selector also changes maxConsumers

          • Major - To be worked after higher priority work items are addressed. When the severity is high and the effort to change it is low to moderate, this term is chosen. Issues in this category likely have an existing workaround but implementation or execution may be non-trivial.
          • Closed

          Activity

            People

              rh-ee-ataylor Andy Taylor
              rhn-support-shiggs Stephen Higgs
              Oleg Sushchenko Oleg Sushchenko
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: