Hi, I tried searching the mailing list archive for an answer but to no avail. So here's yet another question on networks of brokers. I am using activemq 5.0, I want to configure a network of brokers with a given topology, that is deciding which broker is to be connected to which (using multiple network connectors). From the online documentation and examples from this mailing list for a simple 1-to-1 connection among brokers I use the following conf files:
Node1---- <broker xmlns="http://activemq.org/config/1.0"; brokerName="ds-pl3.technion.ac.il" dataDirectory="${activemq.base}/data"> <transportConnectors> <transportConnector name="local" uri="static:(tcp://localhost:7001)"/> </transportConnectors> <networkConnectors> <networkConnector name="S2" dynamicOnly="true" networkTTL="15" duplex="true" uri="static://(tcp://planetlab1.tmit.bme.hu:7002)"/> </networkConnectors> </broker> Node2---- <broker xmlns="http://activemq.org/config/1.0"; brokerName="planetlab1.tmit.bme.hu" dataDirectory="${activemq.base}/data"> <transportConnectors> <transportConnector name="local" uri="static:(tcp://localhost:7002)"/> </transportConnectors> <networkConnectors> <networkConnector name="S1" dynamicOnly="true" networkTTL="15" duplex="true" uri="static://(tcp://ds-pl3.technion.ac.il:7001)"/> </networkConnectors> </broker> ----- I use a single topic and messages seem to flow nicely from a broker to the other (I have a generic distributed pub/sub system with clients that are both producers and consumers attached to each broker). Looking at the standard error on both nodes I get a bunch of exceptions that just keep repeating: some are of severity WARNING, some are SEVERE although they look the same to me. Can anybody please tell me how to get rid of them? Can you please tell me what I am doing wrong? Exceptions follow: WARNING: Failed to add Connection javax.jms.InvalidClientIDException: Broker: ds-pl3.technion.ac.il - Client: NC_planetlab1.tmit.bme.hu_inboundds-pl3.technion.ac.il already connected from vm://ds-pl3.technion.ac.il#6 at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:205) at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81) at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:72) at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81) at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:91) at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:657) at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:125) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178) at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:100) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67) at org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:202) at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98) at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36) Mar 31, 2008 2:20:51 PM org.apache.activemq.broker.TransportConnection serviceException SEVERE: Async error occurred: javax.jms.InvalidClientIDException: Broker: ds-pl3.technion.ac.il - Client: NC_planetlab1.tmit.bme.hu_inboundds-pl3.technion.ac.il already connected from vm://ds-pl3.technion.ac.il#6 javax.jms.InvalidClientIDException: Broker: ds-pl3.technion.ac.il - Client: NC_planetlab1.tmit.bme.hu_inboundds-pl3.technion.ac.il already connected from vm://ds-pl3.technion.ac.il#6 at org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:205) at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81) at org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:72) at org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:81) at org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:91) at org.apache.activemq.broker.TransportConnection.processAddConnection(TransportConnection.java:657) at org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:125) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:281) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:178) at org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:100) at org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:67) at org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:202) at org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98) at org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36) -- View this message in context: http://www.nabble.com/Network-of-brokers---already-connected-tp16396907s2354p16396907.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
