activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From yudy <>
Subject Problems with a network of brokers using embedded brokers
Date Fri, 09 Jun 2006 00:53:48 GMT

I'm trying to create a network of brokers using embedded brokers when I
startup all brokers it seems that all of them established the connections
between them but when I send a message from a broker I can receive it from
another.  I'm using ActiveMQ4 and this the code I'm using to configure the
embedded broker and the network of brokers maybe there is something wrong
with the code. 

			broker = new BrokerService();
			try {
				if (DMSnodesUrls != null) {
					StringBuffer urlList = new StringBuffer();
					for (String url : DMSnodesUrls) {
						urlList.append(url + ',');
					String list = urlList.substring(0, urlList.length() - 1);
					NetworkConnector nc = broker.addNetworkConnector("static:("
							+ list+")");
					try {
						Method m = nc.getClass().getMethod("setFailover", Boolean.TYPE);
						m.invoke(nc, true);
					} catch (Exception e) {
						log.warn("Can't set a failover network of brokers.");

I really appreciate any help on this.
Best regards
View this message in context:
Sent from the ActiveMQ - User forum at

View raw message