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 5264A7AD4 for ; Mon, 15 Aug 2011 15:50:52 +0000 (UTC) Received: (qmail 8386 invoked by uid 500); 15 Aug 2011 15:50:52 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 8137 invoked by uid 500); 15 Aug 2011 15:50:51 -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 8117 invoked by uid 99); 15 Aug 2011 15:50:50 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 15 Aug 2011 15:50:50 +0000 X-ASF-Spam-Status: No, hits=-2001.1 required=5.0 tests=ALL_TRUSTED,RP_MATCHES_RCVD X-Spam-Check-By: apache.org Received: from [140.211.11.116] (HELO hel.zones.apache.org) (140.211.11.116) by apache.org (qpsmtpd/0.29) with ESMTP; Mon, 15 Aug 2011 15:50:49 +0000 Received: from hel.zones.apache.org (hel.zones.apache.org [140.211.11.116]) by hel.zones.apache.org (Postfix) with ESMTP id 19F8DBDFF1 for ; Mon, 15 Aug 2011 15:50:29 +0000 (UTC) Date: Mon, 15 Aug 2011 15:50:29 +0000 (UTC) From: "Hariharan (JIRA)" To: dev@activemq.apache.org Message-ID: <1802199610.38558.1313423429103.JavaMail.tomcat@hel.zones.apache.org> In-Reply-To: <1571522942.36873.1313305227504.JavaMail.tomcat@hel.zones.apache.org> Subject: [jira] [Updated] (AMQ-3450) Acknowledging prefetched messages using client acknowledge mode 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-3450?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ] Hariharan updated AMQ-3450: --------------------------- Attachment: my_client.pl > Acknowledging prefetched messages using client acknowledge mode > --------------------------------------------------------------- > > Key: AMQ-3450 > URL: https://issues.apache.org/jira/browse/AMQ-3450 > Project: ActiveMQ > Issue Type: Bug > Components: Broker > Reporter: Hariharan > Labels: broker > Attachments: my_client.pl > > > We have a situation in front of us and its explained as below: > 1. We have durable subscriber subscribed to a topic. > 2. This durable subscriber is a perl script which is run by a daemon. > 3. The perl script uses stomp to connect to the broker. > 4. The perl script wakes up every 5 mins, checks for messages in the topic and processes them in a batch by pre-fetching the messages. > 5. The subscriber uses a client acknowledgement and acknowledges only the last message of the batch. > 6. We are using AMQ 5.5 with kahaDB persistence. > Now what we see is, > 1. Even though the messages are processed in a batch and the last message is acknowledged the inflight count does not come down. > 2. Enqueue count, Dequeue count and Dispatch count do not match. > 3. The journal files are not getting cleaned up. > I do understand that the journal files would be cleaned up once the references to the messages are lost or removed (i.e. the messages are consumed). But does it have to do anything with the various count attributes I see on the topic? > Also should I expect the inflight count to come down to 0 if client crashes and then consumes all messages after come back live? > I also see that dequeue count stays at 0 even when the dispatch count and the inflight counts change. I believe dequeue count has got a direct relation with messages getting removed from the topic. > Please let me know if there could be any other reason that could cause the journal files to stay back. > Thank you > Hari -- This message is automatically generated by JIRA. For more information on JIRA, see: http://www.atlassian.com/software/jira