Return-Path: X-Original-To: apmail-activemq-dev-archive@www.apache.org Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id 8325C106B5 for ; Wed, 19 Mar 2014 15:37:54 +0000 (UTC) Received: (qmail 92461 invoked by uid 500); 19 Mar 2014 15:37:53 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 91987 invoked by uid 500); 19 Mar 2014 15:37:47 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 91797 invoked by uid 99); 19 Mar 2014 15:37:44 -0000 Received: from arcas.apache.org (HELO arcas.apache.org) (140.211.11.28) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 19 Mar 2014 15:37:44 +0000 Date: Wed, 19 Mar 2014 15:37:44 +0000 (UTC) From: "Gary Tully (JIRA)" To: dev@activemq.apache.org Message-ID: In-Reply-To: References: Subject: [jira] [Resolved] (AMQ-5089) Inflight Count for topics is not correct MIME-Version: 1.0 Content-Type: text/plain; charset=utf-8 Content-Transfer-Encoding: 7bit X-JIRA-FingerPrint: 30527f35849b9dde25b450d4833f0394 [ https://issues.apache.org/jira/browse/AMQ-5089?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Gary Tully resolved AMQ-5089. ----------------------------- Resolution: Fixed Fix Version/s: 5.10.0 fix in http://git-wip-us.apache.org/repos/asf/activemq/commit/b136df17 client ack is now respected for topics subs - and counters decremented on ack rather than on delivered ack. expired case now has its own ack type so it can be separate from delivered ack. > 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 > Assignee: Gary Tully > Priority: Minor > Fix For: 5.10.0 > > > 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)