The following statement, taken from your standard error output, tells me that the broker w/the name "ds-pl3.technion.ac.il" is rejecting a connection request from a client because the client is trying to use a client id (NC_planetlab1.tmit.bme.hu_inboundds-pl3.technion.ac.il) that is already in use.
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 Joe Goto www.ttmsolutions.com for a free ActiveMQ user guide toff wrote: > > 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-tp16396907s2354p16397742.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
