Return-Path: Delivered-To: apmail-activemq-dev-archive@www.apache.org Received: (qmail 72995 invoked from network); 14 Feb 2008 09:46:49 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.2) by minotaur.apache.org with SMTP; 14 Feb 2008 09:46:49 -0000 Received: (qmail 70013 invoked by uid 500); 14 Feb 2008 09:46:43 -0000 Delivered-To: apmail-activemq-dev-archive@activemq.apache.org Received: (qmail 69989 invoked by uid 500); 14 Feb 2008 09:46:43 -0000 Mailing-List: contact dev-help@activemq.apache.org; run by ezmlm Precedence: bulk List-Help: List-Unsubscribe: List-Post: List-Id: Reply-To: dev@activemq.apache.org Delivered-To: mailing list dev@activemq.apache.org Received: (qmail 69974 invoked by uid 99); 14 Feb 2008 09:46:43 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 Feb 2008 01:46:43 -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: local policy) Received: from [203.217.22.128] (HELO file1.syd.nuix.com.au) (203.217.22.128) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 14 Feb 2008 09:45:57 +0000 Received: from [192.168.1.2] (124-170-188-227.dyn.iinet.net.au [124.170.188.227]) by file1.syd.nuix.com.au (Postfix) with ESMTP id DA5BA4A81C0 for ; Thu, 14 Feb 2008 20:45:29 +1100 (EST) Message-ID: <47B40DE4.4010403@nuix.com> Date: Thu, 14 Feb 2008 20:46:12 +1100 From: David Sitsky User-Agent: Thunderbird 2.0.0.9 (Windows/20071031) MIME-Version: 1.0 To: dev@activemq.apache.org Subject: Re: Question about Queue.removeSubscription() References: <47B379A5.10906@nuix.com> <944F227A-0A58-4C25-9BF1-2B7D388E4FB5@gmail.com> In-Reply-To: <944F227A-0A58-4C25-9BF1-2B7D388E4FB5@gmail.com> Content-Type: text/plain; charset=ISO-8859-1; format=flowed Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org > The reason for redelivering messages when a subscription is removed is > because other subscriptions may have originally disocunted those > messages because they were locked when they came to try and dispatch them. That's interesting... because with the current code these messages are left on the pending list. What you say makes sense for a better implementation. > The whole Queue dispatch model is not very scalable because each message > is being delivered to each subscription - this, I think was done because > it made the implementation of exclusive consumer easier. > I'm currently moving away from this model - to decide at Queue dispatch > time which subscription should get the message - just like a - well a > Queue! I think that makes a lot of sense! I want my application to scale to 32 or 64 consumers hammering away, and with the current implementation, I can't see that happening. It all sounds great Rob - any rough ideas when this might ready? Let me know and I'll give it a good workout. :) Cheers, David