Hi, netwrok connector doesn't support prefetchSize property.
http://activemq.apache.org/networks-of-brokers.html#NetworksofBrokers-NetworkConnectorProperties Can uou raise an enhancement request for this in Jira? Cheers -- Dejan Bosanac Open Source Integration - http://fusesource.com/ ActiveMQ in Action - http://www.manning.com/snyder/ Blog - http://www.nighttale.net On Wed, Jun 10, 2009 at 1:48 AM, yinghe0101 <yinghe0...@yahoo.com> wrote: > > 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. > >
