Mailing-List: contact users-help@activemq.apache.org; run by ezmlm
Precedence: bulk
Reply-To: users@activemq.apache.org
Received-SPF: pass (nike.apache.org: domain of lists@nabble.com designates
 216.139.236.158 as permitted sender)
Message-ID: <23953256.post@talk.nabble.com>
Date: Tue, 9 Jun 2009 16:48:56 -0700 (PDT)
From: yinghe0101 <yinghe0101@yahoo.com>
To: users@activemq.apache.org
Subject: PrefetchSize for networkConnector
MIME-Version: 1.0
Content-Type: text/plain; charset=us-ascii
Content-Transfer-Encoding: 7bit


hi,
I have an issue which greatly reduces the quality of service of a network of
activemq brokers.

Here is what I have:
1. 4 brokers( broker1, broker2, broker3,  broker4) in a network by multicast
discovery

2. i have 2 consumers of QueueA on broker1, 2 consumers of QueueA on
broker2, and consumer queuePrefetch=1, networkConnector prefetchSize=1.
Queue is using RoundRobinDispatchPolicy

3. I publish to QueueA on broker3 with 100 msgs, 2 consumers on broker1 are
fast and they process fine but 2 consumers on broker2 are stuck. However,
with this config, msgs are still 50 goes to broker1, 50 goes to broker2, and
when consumers on broker2 get stuck, those 50 msgs are stuck on broker2. It
seems the prefetchSize=1 on networkConnector have no effect at all.

what I expect in this case will be that 98 msgs shall go to broker1, and
only 2 msgs stuck on broker2's consumers. I cannot lose a single msg so
ConstantPendingMessageLimit will not help.

Can anyone help? This is quite urgent. I will appreciate any suggestion. 

best,
Ying
-- 
View this message in context: http://www.nabble.com/PrefetchSize-for-networkConnector-tp23953256p23953256.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.