Using hawtio to look at Topic messages

99 views
Skip to first unread message

nomit babraa

unread,
Nov 29, 2018, 9:48:57 AM11/29/18
to haw...@googlegroups.com
Hi

I can see that hawtio allows browsing of messages at the consumer
level but it seems to show all messages. My (Durable) Consumer of the
topic of interest has 3 pending messages to dequeue.

Is there anyway to just see the pending messages for this consumer?

Thanks

--
Nomit Babraa

Student Lifecycle Project: Monday - Thursday
CiCS: Friday only

Tel: 0114 222 1162

abri...@redhat.com

unread,
Nov 29, 2018, 12:42:07 PM11/29/18
to hawtio
What Hawtio and ActiveMQ version are you using?

abri...@redhat.com

unread,
Nov 30, 2018, 12:20:28 PM11/30/18
to hawtio
hawtio-app-2.3.0.jar and AMQ 5.15.0

abri...@redhat.com

unread,
Dec 3, 2018, 7:54:26 AM12/3/18
to hawtio
Nomit, I got in touch with a colleague and he sent me the following answer to your question:


I took a look at 5.11++ and we don't show pending, and I'm guessing still don't. Pending is the number currently awaiting delivery which would be the total amount enqueued
http://localhost:8181/hawtio/jolokia/read/org.apache.activemq:type=Broker,brokerName=amq,destinationType=Queue,destinationName=TEST/EnqueueCount

minus those that are currently 'in flight', i.e. have been sent but not acknowledged by a consumer
http://localhost:8181/hawtio/jolokia/read/org.apache.activemq:type=Broker,brokerName=amq,destinationType=Queue,destinationName=TEST/InFlightCount

minus those that have been sent and acknowledged by a consumer, i.e. dequeued:
http://localhost:8181/hawtio/jolokia/read/org.apache.activemq:type=Broker,brokerName=amq,destinationType=Queue,destinationName=TEST/DequeueCount

However, I don't know that doing the calculation this way will lead you to a number that is always correct as depending on the configuration and circumstances messages could be potentially consumed by multiple consumers, i.e. in the case of a topic.

But to get back to the original question as stated, it doesn't appear that this is something we expose directly. It is interesting that we have both an 'in flight' count as above and a 'dispatch count':
http://localhost:8181/hawtio/jolokia/read/org.apache.activemq:type=Broker,brokerName=amq,destinationType=Queue,destinationName=TEST/DispatchCount

Which differ only by the known versus in doubt quality of the send:
InFlight
"
Number of messages that have been dispatched to, but not acknowledged by, consumers.
"

Dispatch
"
Number of messages that have been delivered (but potentially not acknowledged) to consumers.
"
Reply all
Reply to author
Forward
0 new messages