Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 99439 invoked from network); 5 Jun 2009 15:51:36 -0000 Received: from hermes.apache.org (HELO mail.apache.org) (140.211.11.3) by minotaur.apache.org with SMTP; 5 Jun 2009 15:51:36 -0000 Received: (qmail 11794 invoked by uid 500); 5 Jun 2009 15:51:47 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 11754 invoked by uid 500); 5 Jun 2009 15:51:47 -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 11744 invoked by uid 99); 5 Jun 2009 15:51:47 -0000 Received: from athena.apache.org (HELO athena.apache.org) (140.211.11.136) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 05 Jun 2009 15:51:47 +0000 X-ASF-Spam-Status: No, hits=-0.0 required=10.0 tests=SPF_HELO_PASS,SPF_PASS X-Spam-Check-By: apache.org Received-SPF: pass (athena.apache.org: domain of lists@nabble.com designates 216.139.236.158 as permitted sender) Received: from [216.139.236.158] (HELO kuber.nabble.com) (216.139.236.158) by apache.org (qpsmtpd/0.29) with ESMTP; Fri, 05 Jun 2009 15:51:38 +0000 Received: from isper.nabble.com ([192.168.236.156]) by kuber.nabble.com with esmtp (Exim 4.63) (envelope-from ) id 1MCbhN-0002t5-RK for users@activemq.apache.org; Fri, 05 Jun 2009 08:51:17 -0700 Message-ID: <23890813.post@talk.nabble.com> Date: Fri, 5 Jun 2009 08:51:17 -0700 (PDT) From: MicAnn To: users@activemq.apache.org Subject: Remote/local delivery and ConsumerCount management MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Nabble-From: mbrusa@axway.com X-Virus-Checked: Checked by ClamAV on apache.org Parameters: apache-activemq-5.2.0 two ore more brokers connected by bridge connector. Actives consumers ------------------ When a first remote consumer works to listen messages from a queue, the queue is defined on other brokers (if it doesn't exist) and the ConsumerCount attribute is incremented (visible with JMX console) For each local consumer, ConsumerCount is also incremented. Messages sent to this queue are delivered to active consumers in accordance with the ConsumerCount value. Stopping consumers ------------------- When a local consumer stops to work, ConsumerCount is decremented? When the all remote consumers stop to work the ConsumerCount is not affected. Repercussions ------------- When a remote consumer listen one time and stops, future messages sent to the queue will be delivered to the remote queue without consumer. When all consumers stop (local and remote), message sent to the local queue will be delivered to the remote queue. Suggestion ----------- When the last queue consumer stops on a broker, an information will be send to the other brokers to manage the ConsumerCount and do -1. Otherwise, the delivery of messages is distorted - usage with difficulty or impossible : it needs to stop remote or local broker to decremented the ConsumerCount attribute. -- View this message in context: http://www.nabble.com/Remote-local-delivery-and-ConsumerCount-management-tp23890813p23890813.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.