activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From schow <sc...@alarmpoint.com>
Subject Re: Configuring Distributed Queues in Store/Forward Network
Date Tue, 12 Oct 2010 16:54:28 GMT


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.

Mime
View raw message