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

Regression CR5 - artemis queue stat is not working with older artemis versions

XMLWordPrintable

      7.12.0 CR5 artemis queue is not working with older release (7.12.0 CR4 and older).

      ❯ /home/mtoth/Downloads/apache-artemis-2.33.0.redhat-00007/lala/bin/artemis queue stat --url tcp://HOST1:61616
      Connection brokerURL = tcp://HOST1:61616
      java.lang.NullPointerException: no mapping for internalQueue
      	at org.apache.activemq.artemis.commons.shaded.johnzon.core.JsonObjectImpl.valueOrExcpetion(JsonObjectImpl.java:52)
      	at org.apache.activemq.artemis.commons.shaded.johnzon.core.JsonObjectImpl.getString(JsonObjectImpl.java:85)
      	at org.apache.activemq.artemis.json.impl.JsonObjectImpl.getString(JsonObjectImpl.java:68)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.getColumnSizes(StatQueue.java:293)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.printStats(StatQueue.java:268)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.lambda$printStats$1(StatQueue.java:227)
      	at org.apache.activemq.artemis.api.core.management.ManagementHelper.doManagement(ManagementHelper.java:127)
      	at org.apache.activemq.artemis.api.core.management.ManagementHelper.doManagement(ManagementHelper.java:111)
      	at org.apache.activemq.artemis.cli.commands.messages.BasicConnectionAbstract.performCoreManagement(BasicConnectionAbstract.java:90)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.printStats(StatQueue.java:223)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.singleExeuction(StatQueue.java:212)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.execute(StatQueue.java:172)
      	at org.apache.activemq.artemis.cli.Artemis.internalExecute(Artemis.java:221)
      	at org.apache.activemq.artemis.cli.Artemis.execute(Artemis.java:167)
      	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
      	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
      	at org.apache.activemq.artemis.boot.Artemis.execute(Artemis.java:157)
      	at org.apache.activemq.artemis.boot.Artemis.main(Artemis.java:64)
      

      Reproducing steps

      • Deploy older broker (7.12.0 CR4 and older 7.11 or 7.10.x)
      • Send few messages there (optional)
      • Execute artemis queue stat from 7.12.0 CR5 broker
      [fedora@HOST1 ~]$ artemis228/bin/artemis run
                 __  __  ____    ____            _
           /\   |  \/  |/ __ \  |  _ \          | |
          /  \  | \  / | |  | | | |_) |_ __ ___ | | _____ _ __
         / /\ \ | |\/| | |  | | |  _ <| '__/ _ \| |/ / _ \ '__|
        / ____ \| |  | | |__| | | |_) | | | (_) |   <  __/ |
       /_/    \_\_|  |_|\___\_\ |____/|_|  \___/|_|\_\___|_|
      
       Red Hat AMQ Broker 7.11.1.GA
      
      
      
      ====
      
      Different host
      7.12.0 CR5
      
      ❯ /home/mtoth/Downloads/apache-artemis-2.33.0.redhat-00007/lala/bin/artemis producer --destination lala --url tcp://HOST1:61616 --message-count 10
      Connection brokerURL = tcp://HOST1:61616
      Producer ActiveMQQueue[lala], thread=0 Started to calculate elapsed time ...
      
      Producer ActiveMQQueue[lala], thread=0 Produced: 10 messages
      Producer ActiveMQQueue[lala], thread=0 Elapsed time in second : 1 s
      Producer ActiveMQQueue[lala], thread=0 Elapsed time in milli second : 1390 milli seconds
      
      7.12.0 CR5
      ❯ /home/mtoth/Downloads/apache-artemis-2.33.0.redhat-00007/lala/bin/artemis queue stat --url tcp://HOST1:61616
      Connection brokerURL = tcp://HOST1:61616
      java.lang.NullPointerException: no mapping for internalQueue
      	at org.apache.activemq.artemis.commons.shaded.johnzon.core.JsonObjectImpl.valueOrExcpetion(JsonObjectImpl.java:52)
      	at org.apache.activemq.artemis.commons.shaded.johnzon.core.JsonObjectImpl.getString(JsonObjectImpl.java:85)
      	at org.apache.activemq.artemis.json.impl.JsonObjectImpl.getString(JsonObjectImpl.java:68)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.getColumnSizes(StatQueue.java:293)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.printStats(StatQueue.java:268)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.lambda$printStats$1(StatQueue.java:227)
      	at org.apache.activemq.artemis.api.core.management.ManagementHelper.doManagement(ManagementHelper.java:127)
      	at org.apache.activemq.artemis.api.core.management.ManagementHelper.doManagement(ManagementHelper.java:111)
      	at org.apache.activemq.artemis.cli.commands.messages.BasicConnectionAbstract.performCoreManagement(BasicConnectionAbstract.java:90)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.printStats(StatQueue.java:223)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.singleExeuction(StatQueue.java:212)
      	at org.apache.activemq.artemis.cli.commands.queue.StatQueue.execute(StatQueue.java:172)
      	at org.apache.activemq.artemis.cli.Artemis.internalExecute(Artemis.java:221)
      	at org.apache.activemq.artemis.cli.Artemis.execute(Artemis.java:167)
      	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke0(Native Method)
      	at java.base/jdk.internal.reflect.NativeMethodAccessorImpl.invoke(NativeMethodAccessorImpl.java:77)
      	at java.base/jdk.internal.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:43)
      	at java.base/java.lang.reflect.Method.invoke(Method.java:568)
      	at org.apache.activemq.artemis.boot.Artemis.execute(Artemis.java:157)
      	at org.apache.activemq.artemis.boot.Artemis.main(Artemis.java:64)
      
      7.12.0 CR4
      ❯ /home/mtoth/Downloads/apache-artemis-2.33.0.redhat-00006/bin/artemis queue stat --url tcp://HOST1:61616
      Connection brokerURL = tcp://HOST1:61616
      |NAME                     |ADDRESS                  |CONSUMER_COUNT|MESSAGE_COUNT|MESSAGES_ADDED|DELIVERING_COUNT|MESSAGES_ACKED|SCHEDULED_COUNT|ROUTING_TYPE|
      |DLQ                      |DLQ                      |0             |0            |0             |0               |0             |0              |ANYCAST     |
      |ExpiryQueue              |ExpiryQueue              |0             |0            |0             |0               |0             |0              |ANYCAST     |
      |activemq.management.72...|activemq.management.72...|1             |1            |1             |1               |0             |0              |MULTICAST   |
      |activemq.management.c5...|activemq.management.c5...|1             |0            |0             |0               |0             |0              |MULTICAST   |
      |activemq.management.de...|activemq.management.de...|1             |1            |1             |1               |0             |0              |MULTICAST   |
      |lala                     |lala                     |0             |763          |763           |0               |0             |0              |ANYCAST     |
      
      7.11.x
      ❯ /home/mtoth/Downloads/apache-artemis-2.28.0.redhat-00015/lala-711/bin/artemis queue stat --url tcp://HOST1:61616
      Connection brokerURL = tcp://HOST1:61616
      |NAME                     |ADDRESS                  |CONSUMER_COUNT|MESSAGE_COUNT|MESSAGES_ADDED|DELIVERING_COUNT|MESSAGES_ACKED|SCHEDULED_COUNT|ROUTING_TYPE|
      |DLQ                      |DLQ                      |0             |0            |0             |0               |0             |0              |ANYCAST     |
      |ExpiryQueue              |ExpiryQueue              |0             |0            |0             |0               |0             |0              |ANYCAST     |
      |activemq.management.09...|activemq.management.09...|1             |0            |0             |0               |0             |0              |MULTICAST   |
      |lala                     |lala                     |0             |763          |763           |0               |0             |0              |ANYCAST     |
      

            csuconic@redhat.com Clebert Suconic
            mtoth@redhat.com Michal Toth
            Michal Toth Michal Toth
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

              Created:
              Updated:
              Resolved: