Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 65245 invoked from network); 11 Dec 2008 15:11:59 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 11 Dec 2008 15:11:59 -0000 Received: (qmail 97686 invoked by uid 500); 11 Dec 2008 15:12:11 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 97288 invoked by uid 500); 11 Dec 2008 15:12:10 -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 97277 invoked by uid 99); 11 Dec 2008 15:12:10 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 11 Dec 2008 07:12:10 -0800 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of james.strachan@gmail.com designates 209.85.217.13 as permitted sender) Received: from [209.85.217.13] (HELO mail-gx0-f13.google.com) (209.85.217.13) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 11 Dec 2008 15:11:56 +0000 Received: by gxk6 with SMTP id 6so1263199gxk.14 for ; Thu, 11 Dec 2008 07:11:34 -0800 (PST) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:received:received:message-id:date:from:to :subject:in-reply-to:mime-version:content-type :content-transfer-encoding:content-disposition:references; bh=R5vpgu/vFlHtVZvyYY/bo+Sun7ngGusTEVpRK3llkqE=; b=WDAvRdaSg1l9ip26qoeTG1NrfV6PQbYJrHXQLipN1SgBC4jVIp8h3b2gCuY55wRLv/ PTLWmePzUsSR0NGQSQaj+4CWKath/2Mp5CK6LfZajSLGqEUPjLRCvh8mv6Xec0rPhi/I qlT/h/K4I8Q0gpOXxukmbMJ3JA4D6wBm710d4= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=message-id:date:from:to:subject:in-reply-to:mime-version :content-type:content-transfer-encoding:content-disposition :references; b=lmSrpOL7ZKum5ne4s9l1Z+2uBLy1LAhWuWAjwZLFI9ZMcPmYgyPSLVQzQA+3OQQ9a+ Z7AwBtPgZckk0VtOjqhIJL5Sr6Ie7WWmIPpv3SmW+7hJrpgvp/3pYIm9QRHjSrsMZ9lH JCY5plVZvak4pMBdNOhw5DRP5p7cindTBR+J0= Received: by 10.150.158.10 with SMTP id g10mr4376693ybe.213.1229008294736; Thu, 11 Dec 2008 07:11:34 -0800 (PST) Received: by 10.151.139.7 with HTTP; Thu, 11 Dec 2008 07:11:34 -0800 (PST) Message-ID: Date: Thu, 11 Dec 2008 15:11:34 +0000 From: "James Strachan" To: users@activemq.apache.org Subject: Re: Rollback and acknowledge In-Reply-To: <20956424.post@talk.nabble.com> MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit Content-Disposition: inline References: <20934209.post@talk.nabble.com> <20937721.post@talk.nabble.com> <20952098.post@talk.nabble.com> <20956173.post@talk.nabble.com> <20956424.post@talk.nabble.com> X-Virus-Checked: Checked by ClamAV on apache.org 2008/12/11 mmocnik : > > > > James.Strachan wrote: >> >> 2008/12/11 mmocnik : >>> >>> >>> James.Strachan wrote: >>>> >>>>> [...] >>>> though I think putting redelivered messages at the tail of the queue >>>> (so its dispatched last) is what you want - so resending the message >>>> rather than rolling back & closing is probably more suitable >>>> >>> Yes, that is what I want to achieve, but if I do it that way I'm loosing >>> the >>> benefits of redelivery by ActiveMQ: >>> - RedeliveryDelay (with exponentialBackoff) >>> - RedeliveryLimit >> >> But those don't matter if the next message you are processing is a >> totally different message? >> >> -- >> James >> ------- >> http://macstrac.blogspot.com/ >> >> Open Source Integration >> http://fusesource.com/ >> >> > > Well, not for the next message, but for the message I want to resend. Sending the message to be rolled back to the head of the queue will add a delay (since consumers will have to process all pending messages first). If you want an explicit delay before republishing the message I'd suggest using Camel with the delayer... http://activemq.apache.org/camel/delayer.html so you'd send to the delay queue with some timeout; then the delayer could then route it back to the queue -- James ------- http://macstrac.blogspot.com/ Open Source Integration http://fusesource.com/