activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From fehm <Felix....@cern.ch>
Subject Re: Network of brokers acknowledgments
Date Wed, 23 Sep 2009 13:07:14 GMT

Hi,


you may want to try to enable dynamicOnly=true in the NetworkConnector
properties. 
please check here (http://activemq.apache.org/networks-of-brokers.html).


Cheers,
Felix



Carlos Quiroz wrote:
> 
> Hi
> 
> I have been trying to use a network of brokers to get load balancing and
> scale horizantally
> 
> Right now I have a single AMQ 5.2 instance and my consumers connect
> sporadically to it using durable subscriptions. The clients are often
> disconnected and they need to fetch the messages generated while they were
> offline. Notice that the messages are directed to a specific client and
> they should be delivered only once
> 
> I setup a network of brokers let's call them A,B and my objective is that
> clients can connect to either. Both A and B have producers sending
> messages to any client. Now I tested that if a message is produced and
> sent to A, the client can fetch it from A fine. Also if the message is
> sent to A, it is then distributed to B and the client can fetch it in B.
> So this works exactly as I wanted
> 
> Now this scenario doesn't work:
> 
> msg1 sent to A
> client connects to A and fetches msg1
> client disconnects from A
> client connects to B and msg1 is delivered again!!
> 
> So it seems to me that the acks on A are not being transferred to B
> 
> Is this by design or am I doing something wrong
> 
> My config is as follow
> 
> Broker A
> 	<broker xmlns="http://activemq.apache.org/schema/core"
> 		persistent="true" populateJMSXUserID="true" brokerName="brokerA"
> 		advisorySupport="true" useJmx="true">
> 		<networkConnectors>
> 			<networkConnector uri="static:(tcp://addressB:61617)"
> 			duplex="true"
> 			</networkConnector>
> 		</networkConnectors>
> 
> Broker B
> 	<broker xmlns="http://activemq.apache.org/schema/core"
> 		persistent="true" populateJMSXUserID="true" brokerName="brokerB"
> 		advisorySupport="true" useJmx="true">
> 		<networkConnectors>
> 			<networkConnector uri="static:(tcp://addressA:61617)"
> 			duplex="true"
> 			</networkConnector>
> 		</networkConnectors>
> 
> 
> Thanks for any help
> 
> Carlos Quiroz
> 

-- 
View this message in context: http://www.nabble.com/Network-of-brokers-acknowledgments-tp25531077p25531124.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message