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.