I'm stumped by how to use the filter for countMessages(String, String) in
the console view for queue operations. My goal is to get a count of
messages grouped by clientID.

I boot up a broker and send 3000 messages with 3 different clientIDs.

bin/artemis producer --destination exampleQueue --url tcp://localhost:61616
--user admin --password password --clientID homer
bin/artemis producer --destination exampleQueue --url tcp://localhost:61616
--user admin --password password --clientID barney
bin/artemis producer --destination exampleQueue --url tcp://localhost:61616
--user admin --password password --clientID moe

In the console, I get 3000 messages for messageCount(), and
messageCount(String) with an empty filter. I can see the _AMQ_CID property
is set on the messages with browse().

    "StringProperties": {
      "ThreadSent": "Producer ActiveMQQueue[exampleQueue], thread=0",
      "__AMQ_CID": "homer"
    },

But the result for countMessages("", "__AMQ_CID")  is nonsensical. It only
returns {"homer":200} when I expect a list of homer, barney, and moe each
with 1000 messages.

[image: image.png]

I couldn't find any reference to this in the docs or find any examples/unit
tests using the groupByProperty. Thanks for any help.

Reply via email to