You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by rakeshbalguri <ra...@yahoo.com> on 2016/03/22 17:15:21 UTC

Messages not received in hub/spoke configuration

Hi all,I am configuring my ActiveMQ instances in a Hub/Spoke Topology. I am
using the BrokerService class to start the broker and adding the network
connectors. The network connection is a duplex connection.Note: I am using
*ActiveMQ 5.13.2*The configuration is as follows:Producer---->
Broker1------>Hub(Broker3)<-------Broker2<------ConsumerIn the above
configuration, I produce the message to Broker1 and since all the three
brokers are connected in a duplex network, I expect that the message
produced to Broker1 is consumed by Broker3But no messages are being consumed
from the Broker2.If I register the consumer from Broker3, I get all the
messages that are produced.The following is the code snippet I am using for
the Brokers: embeddedBrokerService = new BrokerService();
embeddedBrokerService.setBrokerName(UUID.randomUUID().toString());
embeddedBrokerService.setBrokerId(UUID.randomUUID().toString()); final URI
uri = new URI("tcp" + "://" + "192.168.1.1" + ":" + "61616");
embeddedBrokerService.addConnector(uri); System.out.println("Started the
broker Successfully"); System.out.println("Adding network broker for 1");
final NetworkConnector networkConnector =
embeddedBrokerService.addNetworkConnector("static:("                + "tcp"               
+ "://"                + "192.168.1.1"                + ":"                +
"61617"                + ")");        networkConnector.setDuplex(true);       
networkConnector.setName(UUID.randomUUID().toString());       
networkConnector.setNetworkTTL(1);       
networkConnector.setConduitSubscriptions(false);       
embeddedBrokerService.start();Can someone please take a look at this problem
and help me in resolving this issue.Thanks.



--
View this message in context: http://activemq.2283324.n4.nabble.com/Messages-not-received-in-hub-spoke-configuration-tp4709884.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.