It sure would be great to get the stats more meaningful. Sent from my iPhone
> On Mar 11, 2014, at 9:28 AM, "JIRA [email protected] [via ActiveMQ]" > <[email protected]> wrote: > > > [ > 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) > > > If you reply to this email, your message will be added to the discussion > below: > http://activemq.2283324.n4.nabble.com/jira-Commented-AMQ-5089-Inflight-Count-for-topics-is-not-correct-tp4678727.html > To start a new topic under ActiveMQ - Dev, email > [email protected] > To unsubscribe from ActiveMQ - Dev, click here. > NAML -- View this message in context: http://activemq.2283324.n4.nabble.com/Re-jira-Commented-AMQ-5089-Inflight-Count-for-topics-is-not-correct-tp4678730.html Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.
