Return-Path: Delivered-To: apmail-geronimo-activemq-dev-archive@www.apache.org Received: (qmail 45630 invoked from network); 27 Jul 2006 15:52:13 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (209.237.227.199) by minotaur.apache.org with SMTP; 27 Jul 2006 15:52:13 -0000 Received: (qmail 69091 invoked by uid 500); 27 Jul 2006 15:52:13 -0000 Delivered-To: apmail-geronimo-activemq-dev-archive@geronimo.apache.org Received: (qmail 68986 invoked by uid 500); 27 Jul 2006 15:52:13 -0000 Mailing-List: contact activemq-dev-help@geronimo.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: activemq-dev@geronimo.apache.org Delivered-To: mailing list activemq-dev@geronimo.apache.org Received: (qmail 68977 invoked by uid 99); 27 Jul 2006 15:52:13 -0000 Received: from asf.osuosl.org (HELO asf.osuosl.org) (140.211.166.49) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Jul 2006 08:52:13 -0700 X-ASF-Spam-Status: No, hits=0.0 required=10.0 tests= X-Spam-Check-By: apache.org Received-SPF: pass (asf.osuosl.org: local policy) Received: from [207.25.178.46] (HELO mx03.lexisnexis.com) (207.25.178.46) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 27 Jul 2006 08:52:12 -0700 Received: from mailgate2.lexis-nexis.com ([138.12.44.45]) by mx03.lexisnexis.com with ESMTP; 27 Jul 2006 11:51:51 -0400 Received: from lngdayexcp001.legal.regn.net (smtpgate.lexis-nexis.com [10.113.1.1]) by mailgate2.lexis-nexis.com (8.12.11/8.12.11) with ESMTP id k6RFpmNP016227 for ; Thu, 27 Jul 2006 11:51:51 -0400 Received: from LNGDAYEXCP01VA.legal.regn.net ([10.113.1.3]) by lngdayexcp001.legal.regn.net with Microsoft SMTPSVC(6.0.3790.2499); Thu, 27 Jul 2006 11:51:51 -0400 X-MimeOLE: Produced By Microsoft Exchange V6.5 Content-class: urn:content-classes:message MIME-Version: 1.0 Content-Type: text/plain; charset="us-ascii" Content-Transfer-Encoding: quoted-printable Subject: RE: message ack timeout question. Date: Thu, 27 Jul 2006 11:51:50 -0400 Message-ID: X-MS-Has-Attach: X-MS-TNEF-Correlator: Thread-Topic: message ack timeout question. Thread-Index: Acaxka0KPo87dx0USL+SZnXPnJUGZgAAe5gg From: "Dhawan, Vikram \(LNG-DAY\)" To: X-OriginalArrivalTime: 27 Jul 2006 15:51:51.0451 (UTC) FILETIME=[937F56B0:01C6B194] X-Scanned-By: MIMEDefang 2.51 on 138.12.44.45 X-Virus-Checked: Checked by ClamAV on apache.org X-Spam-Rating: minotaur.apache.org 1.6.2 0/1000/N Hey James,=20 Thanks for the response, it make sense.=20 Sorry about the empty thread, subject line was dropped in the first one so I thought I should add it and sent it again for better readability.=20 I have noticed another thing though.=20 If I have few messages in a queue (lets say 10) and bring consumer-1 up. If I don't call receive still consumer-1 locks all the 10 messages (and shows in the Dequeue count in JMX console). And now if I bring another consumer-2 and calls receive consumer-2 doesn't get any message.=20 Even if I haven't received any message in consumer-1 and all the messages are still new.=20 Please advice.=20 Thanks! Vik -----Original Message----- From: James Strachan [mailto:james.strachan@gmail.com]=20 Sent: Thursday, July 27, 2006 11:30 AM To: activemq-dev@geronimo.apache.org Subject: Re: message ack timeout question. I just responded to the other empty thread - thought I'd resend my reply... On 7/27/06, Dhawan, Vikram (LNG-DAY) wrote: > Hi, > > I have a question regarding receive/acknowledge model in AMQ. > > If there are 2 consumers (running on separate machines) connected to AMQ > server on the same queue. Consumer-1 receives a message and don't send > acknowledge. Is consumer-2 will be able to receive this messages ever > without consumer-1 explicitly disconnects from the AMQ server. No - consumer 2 will not receive the message until consumer 1 terminates (or is disconnected from the broker). At some point we could add some kinda inactivity timeout in consumers so that if they grab messages and don't process them we silently disconnect the consumer (so they give their prefetches back). --=20 James ------- http://radio.weblogs.com/0112098/