Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 83555 invoked from network); 30 Apr 2009 03:26:48 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 30 Apr 2009 03:26:48 -0000 Received: (qmail 16708 invoked by uid 500); 30 Apr 2009 03:26:47 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 16643 invoked by uid 500); 30 Apr 2009 03:26:46 -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 16633 invoked by uid 99); 30 Apr 2009 03:26:46 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 30 Apr 2009 03:26:46 +0000 X-ASF-Spam-Status: No, hits=2.2 required=10.0 tests=HTML_MESSAGE,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (nike.apache.org: domain of gseben@gmail.com designates 74.125.92.144 as permitted sender) Received: from [74.125.92.144] (HELO qw-out-1920.google.com) (74.125.92.144) by apache.org (qpsmtpd/0.29) with ESMTP; Thu, 30 Apr 2009 03:26:36 +0000 Received: by qw-out-1920.google.com with SMTP id 5so1188942qwc.26 for ; Wed, 29 Apr 2009 20:26:14 -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:message-id:subject:from:to:content-type; bh=NW0l5dt6noaKnyLEPvzD4JX/k8zKAdOZ/ZP3zVF83wA=; b=ESFE0JpwX3HNitOtEx+7pEFwNwxywWNPs+2ylYNW0jpR7bTxw4tazG4zmbewoTifaC fI8YRV2D4B9sEorY39N4mBEiXKg/oVkKTj469thqEDUjgS+BNBDCaPSLXgDYmR1A0RVh tlnscMcXF1r+kw8D0tbJwlu8UQXjDv12wvf+Q= 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=KQ436FfNMP9YGVOwF//hyBRC0jjJYa83lgyPkKmsg3mF6es1iOx4MXHZCRK9Wu3Szx clhNxKDRCLUF115J1odUP8VZdM4nknrDTCFPc2LWqsiVrtEFZqIlOXcMeSDiyS204MAh /3qzJ5vXYpz/uvQOcKSK85p3CvCtLQXtwLUdE= MIME-Version: 1.0 Received: by 10.229.109.194 with SMTP id k2mr1042133qcp.6.1241061974853; Wed, 29 Apr 2009 20:26:14 -0700 (PDT) In-Reply-To: <23296281.post@talk.nabble.com> References: <23296281.post@talk.nabble.com> Date: Wed, 29 Apr 2009 23:26:14 -0400 Message-ID: <467bc4630904292026x1c6e9b05r214b97e295f20014@mail.gmail.com> Subject: Re: Issues with Network of Brokers and Message Selectors From: Giovani Seben To: users@activemq.apache.org Content-Type: multipart/alternative; boundary=0016361640ad27c8f30468bd425b X-Virus-Checked: Checked by ClamAV on apache.org --0016361640ad27c8f30468bd425b Content-Type: text/plain; charset=ISO-8859-1 Content-Transfer-Encoding: 7bit Elliot, This looks very similar to an issue fixed a couple of months ago. Check out: http://fusesource.com/issues/browse/MB-438 or alternatively for AMQ: https://issues.apache.org/activemq/browse/AMQ-2104 HTH, -Giovani On Wed, Apr 29, 2009 at 1:21 PM, Elliot Barlas wrote: > > I have been experimenting with the behavior of a network of two AMQ brokers > and message selecting consumers. As described in the AMQ documentation > (http://activemq.apache.org/networks-of-brokers.html), consuming with > message selectors in a broker network environment can lead to messages > being > trapped on one of the brokers. > > Setup: > -2 AMQ Brokers connected by static URIs. Using all default settings. > -2 Producers, 1 connected to each Broker. > -Each producer sends 100 non persistent, non expiring messages. > -1 message selecting consumer connects to 1 Broker and consumes all > matching > messages. > -Observation: the 100 messages from the other Broker (without the consumer) > are transferred over, EVEN THOSE MESSAGES THAT DO NOT MATCH THE SELECTOR > EXPRESSION. THOSE MESSAGES ARE NOW TRAPPED ON THAT BROKER. > > How can I avoid transferring messages for which there is no consumer than > can ACTUALLY consume the messages??? > > I have condensed the experiment into a small Java class and attached it: > http://www.nabble.com/file/p23296281/SelectorBrokerNetworkTest.java > SelectorBrokerNetworkTest.java > > Thanks, > Elliot > -- > View this message in context: > http://www.nabble.com/Issues-with-Network-of-Brokers-and-Message-Selectors-tp23296281p23296281.html > Sent from the ActiveMQ - User mailing list archive at Nabble.com. > > --0016361640ad27c8f30468bd425b--