From users-return-17367-apmail-activemq-users-archive=activemq.apache.org@activemq.apache.org Tue Dec 23 14:24:17 2008 Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 66860 invoked from network); 23 Dec 2008 14:24:17 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 23 Dec 2008 14:24:17 -0000 Received: (qmail 32936 invoked by uid 500); 23 Dec 2008 14:24:16 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 32911 invoked by uid 500); 23 Dec 2008 14:24:16 -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 32899 invoked by uid 99); 23 Dec 2008 14:24:16 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 23 Dec 2008 06:24:16 -0800 X-ASF-Spam-Status: No, hits=0.2 required=10.0 tests=SPF_PASS,WHOIS_MYPRIVREG X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of gary.tully@gmail.com designates 209.85.218.15 as permitted sender) Received: from [209.85.218.15] (HELO mail-bw0-f15.google.com) (209.85.218.15) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 23 Dec 2008 14:24:06 +0000 Received: by bwz8 with SMTP id 8so8907061bwz.14 for ; Tue, 23 Dec 2008 06:23:45 -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=iznxdWzeTTItj8bRYoUoTpvh0nD8HnIcaWxsD5BRUv8=; b=oc1lk25WvmFYZaCyReN3u0BhUD+EVlDCQSZFnG9FGdlTBwAwSD2f52MNRbc9SyqRHa b3lBR4dLmPs1YRkQX9kL9MBRbWRCFdZH1c+TYUb651OSyvFVPIM+2bwf2zD4P9OSTeN4 t0ML+AChOllWIlG5LQHfbgQg0AJBsjllRk0b4= 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=RfnFYQMCoB1GgLWBVsMA3G5Wzy7aZU9H5enc2PR6H78PJhIteq0RkYU736WGw7a4Cn IsyoVzbAX46fhKNN7gyX6wuFkaOePm/sWKA0nrCqgFJS6OX3ahxV+Y8heOs7tmDiqoGY Q2TBilO8C1SwIOieELmwPSbIFPYwApgUdfnaE= Received: by 10.180.233.15 with SMTP id f15mr2742329bkh.188.1230042218388; Tue, 23 Dec 2008 06:23:38 -0800 (PST) Received: by 10.181.31.8 with HTTP; Tue, 23 Dec 2008 06:23:38 -0800 (PST) Message-ID: <3a73c17c0812230623p1355a2byd9e8e658fb4a4e6f@mail.gmail.com> Date: Tue, 23 Dec 2008 14:23:38 +0000 From: "Gary Tully" To: users@activemq.apache.org Subject: Re: Loss of dispatched messages In-Reply-To: <21142086.post@talk.nabble.com> MIME-Version: 1.0 Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit Content-Disposition: inline References: <21142086.post@talk.nabble.com> X-Virus-Checked: Checked by ClamAV on apache.org You may just need to make your subscriptions durable: http://activemq.apache.org/how-do-durable-queues-and-topics-work.html but also check out - http://activemq.apache.org/subscription-recovery-policy.html which determines whether a subscription can see messages published before it existed. and for non durable - http://activemq.apache.org/what-is-the-prefetch-limit-for.html which controls the number of pending messages dispatched to a consumer. 2008/12/23 deadfolk : > > Hi All, > > Hopefully an easy one...we have a pub/sub setup with a bunch of Groovy > consumers using the Java client to listen to a bunch of topics. We > terminate these by literally killing the process. When we do this, we seem > to lose any dispatched messages that have not yet been processed. That is > to say, if the web console shows Dispatched Queue size = 1,000 messages, > after restart, we seem to be 1,000 messages short, if I'm reading the web > console correctly. > > Does that make sense? Is there just a configuration entry I can set which > says 'Do not consider a message delivered until the consumer has actually > dealt with it' which will make these messages get processed upon startup of > the consumer? > > I've tried looking throught the docs, but I haven't had much luck. > > Thanks in advance, > > Matt > -- > View this message in context: http://www.nabble.com/Loss-of-dispatched-messages-tp21142086p21142086.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > -- http://blog.garytully.com Open Source SOA http://FUSESource.com