activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Joe Fernandez <joe.fernan...@ttmsolutions.com>
Subject Re: Network of brokers acknowledgments
Date Thu, 01 Oct 2009 14:08:13 GMT

I believe this is working as designed. In the process of connecting to the
two different brokers, your consumer has pollinated the two brokers with the
same 'durable subscription'. 

You may want to consider using Virtual Topics.

http://activemq.apache.org/virtual-destinations.html

Joe
http://www.ttmsolutions.com
 

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


Mime
View raw message