activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Carlos Quiroz <carlos.quiroz-cas...@nokia.com>
Subject Re: Network of brokers acknowledgments
Date Fri, 02 Oct 2009 06:23:35 GMT

Hi

Thanks for the tip. I'll try this next it seems that at least in paper this
should do what I want

Carlos

fehm wrote:
> 
> 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-tp25531077p25710946.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Mime
View raw message