Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 81707 invoked from network); 14 Apr 2010 09:16:11 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 14 Apr 2010 09:16:11 -0000 Received: (qmail 22900 invoked by uid 500); 14 Apr 2010 09:16:10 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 22758 invoked by uid 500); 14 Apr 2010 09:16: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 22750 invoked by uid 99); 14 Apr 2010 09:16:09 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 14 Apr 2010 09:16:09 +0000 X-ASF-Spam-Status: No, hits=2.2 required=10.0 tests=FREEMAIL_FROM,HTML_MESSAGE,RCVD_IN_DNSWL_NONE,SPF_PASS,T_TO_NO_BRKTS_FREEMAIL X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of gary.tully@gmail.com designates 209.85.218.225 as permitted sender) Received: from [209.85.218.225] (HELO mail-bw0-f225.google.com) (209.85.218.225) by apache.org (qpsmtpd/0.29) with ESMTP; Wed, 14 Apr 2010 09:16:04 +0000 Received: by bwz25 with SMTP id 25so6984034bwz.8 for ; Wed, 14 Apr 2010 02:15:43 -0700 (PDT) DKIM-Signature: v=1; a=rsa-sha256; c=relaxed/relaxed; d=gmail.com; s=gamma; h=domainkey-signature:mime-version:received:in-reply-to:references :date:received:message-id:subject:from:to:content-type; bh=XzBQVG7t09CMPvZCFhTBXOxABqTccBhgrn4daiAhYDI=; b=bgN01bX1cdYimy67V5+nAi4Sda0rlJpZKioK4mSsSJaMwCM9ZZgeZPMIx217GEmJr+ eN002HSRlzoKRD9wC/hVRjc/I4p/el5G1XHx6O2qwpgO7LI8mJeRuWt8dIO/5kb2hOSp kIMGELHPPSf6nMdR+Vi61ZRtU4Jp1fy5KnHqw= DomainKey-Signature: a=rsa-sha1; c=nofws; d=gmail.com; s=gamma; h=mime-version:in-reply-to:references:date:message-id:subject:from:to :content-type; b=lGgIB314SDszhqthBt85+9+/MJL1w+aTNBlHnRz++sxkW+E+eegowoc+8Qj8yZZ8uW UiKh6FIY3oczerPA5vzj9DiD6VCU89flit/jFQr5IYz+m7Zxz9BFPtFLwDFsZT5Q0T1s yXg8s2BBznQESQJPdPXyt5dqPFwAT0e14gyXU= MIME-Version: 1.0 Received: by 10.204.65.79 with HTTP; Wed, 14 Apr 2010 02:15:42 -0700 (PDT) In-Reply-To: <4BC4BB59.90303@e-dialog.com> References: <4BC4BB59.90303@e-dialog.com> Date: Wed, 14 Apr 2010 10:15:42 +0100 Received: by 10.204.83.26 with SMTP id d26mr1185847bkl.157.1271236542514; Wed, 14 Apr 2010 02:15:42 -0700 (PDT) Message-ID: Subject: Re: Messages stuck after Client host reboot From: Gary Tully To: users@activemq.apache.org, jcarlson@e-dialog.com Content-Type: multipart/alternative; boundary=0016e6db7ba28ae81704842ed267 X-Virus-Checked: Checked by ClamAV on apache.org --0016e6db7ba28ae81704842ed267 Content-Type: text/plain; charset=ISO-8859-1 The re-dispatch is triggered by the tcp connection dying, netstat can help with the diagnosis here. Check the connection state of the broker port after the client host is rebooted, if the connection is still active, possibly in a timed_wait state, you may need to configure some additional timeout options on the broker side. On 13 April 2010 19:43, Josh Carlson wrote: > I am using client acknowledgements with a prefetch size of 1 with no > message expiration policy. When a consumer subscribes to a queue I can see > that the message gets dispatched correctly. If the process gets killed > before retrieving and acknowledging the message I see the message getting > re-dispatched (correctly). I expected this same behaviour if the host > running the process gets rebooted or crashes. However, after reboot I can > see that the message is stuck in the dispatched state to the consumer that > is long gone. Is there a way that I can get messages re-dispatched when a > host hosting consumer processes gets re-booted? How does it detect the case > when a process dies (even with SIGKILL)? > > I did notice that if I increase my prefetch size and enqueue another > message after the reboot, that activemq will re-dispatch the original > message. However with prefetch size equal to one the message never seems to > get re-dispatched. > -- http://blog.garytully.com Open Source Integration http://fusesource.com --0016e6db7ba28ae81704842ed267--