Return-Path: Delivered-To: apmail-activemq-users-archive@www.apache.org Received: (qmail 35484 invoked from network); 12 Oct 2010 16:54:57 -0000 Received: from unknown (HELO mail.apache.org) (140.211.11.3) by 140.211.11.9 with SMTP; 12 Oct 2010 16:54:57 -0000 Received: (qmail 34329 invoked by uid 500); 12 Oct 2010 16:54:56 -0000 Delivered-To: apmail-activemq-users-archive@activemq.apache.org Received: (qmail 34304 invoked by uid 500); 12 Oct 2010 16:54:56 -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 34296 invoked by uid 99); 12 Oct 2010 16:54:56 -0000 Received: from nike.apache.org (HELO nike.apache.org) (192.87.106.230) by apache.org (qpsmtpd/0.29) with ESMTP; Tue, 12 Oct 2010 16:54:56 +0000 X-ASF-Spam-Status: No, hits=2.3 required=10.0 tests=SPF_HELO_PASS,SPF_SOFTFAIL,URI_HEX X-Spam-Check-By: apache.org Received-SPF: softfail (nike.apache.org: transitioning domain of schow@alarmpoint.com does not designate 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; Tue, 12 Oct 2010 16:54:49 +0000 Received: from joe.nabble.com ([192.168.236.151]) by kuber.nabble.com with esmtp (Exim 4.63) (envelope-from ) id 1P5i7Q-0005te-OM for users@activemq.apache.org; Tue, 12 Oct 2010 09:54:28 -0700 Date: Tue, 12 Oct 2010 09:54:28 -0700 (PDT) From: schow To: users@activemq.apache.org Message-ID: <1286902468750-2992285.post@n4.nabble.com> In-Reply-To: References: <1286483767967-2967501.post@n4.nabble.com> <1286561073327-2968819.post@n4.nabble.com> Subject: Re: Configuring Distributed Queues in Store/Forward Network MIME-Version: 1.0 Content-Type: text/plain; charset=us-ascii Content-Transfer-Encoding: 7bit X-Virus-Checked: Checked by ClamAV on apache.org Dejan Bosanac wrote: > > You can set prefetchSize property on the network connector, which > should help with your use case. > See http://activemq.apache.org/networks-of-brokers.html for more details. > Unfortunately, setting the prefetchSize on the NetworkConnector URL does not change the behaviour. For example, if you set prefetchSize=1, the slow consumer's side of the bridge will receive a message, enqueue it to the local instance of the shared queue and ACK the message. As soon as the producer's side of the bridge receives the ACK, it sends another message and the process continues as fast as the network connection allows. The problem is that the consumer's side of the bridge ACKs the message from the producer's instance of the shared queue independently of the consumer ACKing the messages from the consumer's insatnce of the shared queue. What we discovered through testing is that setting the prefetechSize on the network connection is ineffectual at balancing the distribution of shared queue messages between slow and fast consumers that are consuming from remote instances of the shared queue. As Bruce alluded to, the reason is that the bridge does not maintain/access the state of the actual consumers of the queue for which it is bridging. -- View this message in context: http://activemq.2283324.n4.nabble.com/Configuring-Distributed-Queues-in-Store-Forward-Network-tp2967501p2992285.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.