[
https://issues.apache.org/jira/browse/AMQ-5089?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13930537#comment-13930537
]
Gary Tully commented on AMQ-5089:
---------------------------------
I had a quick peek just now, it looks like we could improve this, we track the
enqueue/dequeue count for a topic sub but don't subtract the difference from
the destination inflight when the consumer goes away with pending acks. As it
stands, one abortive consumer can skew the metric for the destination which
otherwise would be some indication of how slow consumers are. However for
topics the broker does not really care b/c there is no broker side state for
non durable topic subs.
> Inflight Count for topics is not correct
> ----------------------------------------
>
> Key: AMQ-5089
> URL: https://issues.apache.org/jira/browse/AMQ-5089
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.8.0
> Reporter: Anuj Khandelwal
> Priority: Minor
>
> Hi,
> It is coming from:
> http://activemq.2283324.n4.nabble.com/Inflight-Count-for-topics-not-correct-td4678407.html#a4678583
> Problem: Inflight count is not going down for topics once consumer is
> disconnected or sent acknowledgements for the messages it has received.
> For topics once inflight count is increased, it is never going back down.
> Test Scenario:
> When a producer and a consumer connected to the broker but consumer is little
> bit slow, there will be inflight messages in the broker which are not yet
> acknowledged.
> Case 1 :Now after some time when consumer acknowledged the messages, than
> inflight count should decrease, but that is not happening for topics.
> Case 2 :Now If at this point of time, I stop consumer broker should make
> inflight count to '0' because those messages are not inflight now. (for queue
> these are now held messages and for topic those messages are dropped). But
> when I check in Jconsole, I found that: for a queue it is working fine and
> going down to 0 but for topics inflight count is not changing.
> Test Case: I tested with normal java consumer subscribing to a topic, I put
> thread.sleep(5000) while receiving messages. Now consumer will take time to
> acknowledge messages which are received. So that we can see inflight
> messages.
> Now after 5 seconds, consumer has received the messages and also sent
> acknowledgement to the broker but inflight count is not decreasing. Now if I
> disconnects consumer inflight count should go down to '0', again here also it
> is not changing for that topic.
> Thanks,
> Anuj
--
This message was sent by Atlassian JIRA
(v6.2#6252)
