Return-Path: X-Original-To: apmail-activemq-users-archive@www.apache.org Delivered-To: apmail-activemq-users-archive@www.apache.org Received: from mail.apache.org (hermes.apache.org [140.211.11.3]) by minotaur.apache.org (Postfix) with SMTP id D3D49FA81 for ; Wed, 27 Mar 2013 01:19:30 +0000 (UTC) Received: (qmail 8240 invoked by uid 500); 27 Mar 2013 01:19:30 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 8209 invoked by uid 500); 27 Mar 2013 01:19:30 -0000 Mailing-List: contact users-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: users@activemq.apache.org Delivered-To: mailing list users@activemq.apache.org Received: (qmail 8194 invoked by uid 99); 27 Mar 2013 01:19:30 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 27 Mar 2013 01:19:30 +0000 X-ASF-Spam-Status: No, hits=0.9 required=5.0 tests=FREEMAIL_ENVFROM_END_DIGIT,RCVD_IN_DNSWL_LOW,SPF_PASS,URI_HEX X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of tabish121@gmail.com designates 209.85.128.171 as permitted sender) Received: from [209.85.128.171] (HELO mail-ve0-f171.google.com) (209.85.128.171) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 27 Mar 2013 01:19:24 +0000 Received: by mail-ve0-f171.google.com with SMTP id b10so6529281vea.30 for ; Tue, 26 Mar 2013 18:19:03 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=20120113; h=x-received:message-id:date:from:user-agent:mime-version:to:subject :references:in-reply-to:content-type:content-transfer-encoding; bh=OrXzc5X3Abi29KUbsE/am97qzCZ8lpYKU1vSchX2PlU=; b=fDE8wX9WE/59gHdC8gS7ZAFSMtiCPKqDsOH5lXArG9+7HabtRcMmjW5EKgnNroQKNK 0zZWLaTWIeK93MtZUCoGfaDL9A9Rx2vUqEJoAu0axxgUINR4KXgKlIDuFRWD8SeBT2ls pkbR1cRpgYHUfGwFyjimiE6WlmcQDieo1+867YaZSGe/ZNcJVbjDNodLI4fyPTe+FC/A tYCMbSaPCt1FJEnGaGSdo1Bkgjos/aJVFrbdgsuJPGw7ttRIbDRRpDabZXWEYQeBUcVP fYRbWIqRYwiQkb6ftn3ibEpSb32iehoXjkT/foWlIj2m6bdfOkFtx0m5RBg6TgB2qKes GzpQ== X-Received: by 10.52.230.10 with SMTP id su10mr18337701vdc.50.1364347143570; Tue, 26 Mar 2013 18:19:03 -0700 (PDT) Received: from [192.168.2.150] (c-98-218-173-79.hsd1.va.comcast.net. [98.218.173.79]) by mx.google.com with ESMTPS id tp10sm27471544vec.1.2013.03.26.18.18.56 (version=TLSv1 cipher=ECDHE-RSA-RC4-SHA bits=128/128); Tue, 26 Mar 2013 18:19:02 -0700 (PDT) Message-ID: <515248F5.5070104@gmail.com> Date: Tue, 26 Mar 2013 21:18:45 -0400 From: Timothy Bish User-Agent: Mozilla/5.0 (X11; Linux x86_64; rv:17.0) Gecko/20130308 Thunderbird/17.0.4 MIME-Version: 1.0 To: users@activemq.apache.org Subject: Re: persistent message missing to a durable subscriber when it reconnects(restarts) References: <1364279991802-4665130.post@n4.nabble.com> <1364320951942-4665159.post@n4.nabble.com> <1364345368497-4665166.post@n4.nabble.com> In-Reply-To: <1364345368497-4665166.post@n4.nabble.com> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org On 03/26/2013 08:49 PM, Jaewoong Choi wrote: > Unfortunately, I couldn't verify if the latest snapshots resolved the issue I > questioned. I failed to replace the activemq-core dependency from 5.7.0 to > any upper versions as I ended up facing some runtime errors with the API > I've used with 5.7.0. It looks like, including "broker/client split" that > you mentioned, from 5.8.0 the activemq is not that backward compatible with > 5.7.0 and below versions. You probably didn't include the activemq-kahadb-store jar there's also the activemq-all uber module which will bring in everything. > > I have a different question (but for the same purpose: to resolve this > issue). Is there any event handler interface the ActiveMQ provides and I > can hook up, such that I can control store cursors (e.g. AbstractStoreCursor > or TopicStorePrefetch instances) in its implementation? The event of the > interest is "on consumer closing" (or "deactivation of the durable > subscription") in relation with this question thread, so that I can simply > wipe out the store cursor's pending list whenever the subscriber closes it > subscription. To me, reclaiming all inflight messages back to the store > cursor's pending list that the current ActiveMQ approaches seems just too > complicated and not straight forward. I'd rather just clean up the pending > list (store cursor cache) whenever the subscriber closes on the client side > (i.e. subscription becomes deactivated in broker) in order to avoid mess up > the store cursor's internal states... > > > > -- > View this message in context: http://activemq.2283324.n4.nabble.com/persistent-message-missing-to-a-durable-subscriber-when-it-reconnects-restarts-tp4665130p4665166.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > -- Tim Bish Sr Software Engineer | RedHat Inc. tim.bish@redhat.com | www.fusesource.com | www.redhat.com skype: tabish121 | twitter: @tabish121 blog: http://timbish.blogspot.com/