activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ttmdev <joe.fernan...@ttmsolutions.com>
Subject Re: Network of brokers - already connected
Date Tue, 01 Apr 2008 14:14:30 GMT

Please disregard my previous post; it was incorrect! d:(    Thanks G, for
catching my mistake.  

This exception is being thrown because the broker planetlab1.tmit.bme.hu is
trying to set up a demand forwarding bridge with the local broker
pl3.technion.ac.il, but pl3.technion.ac.il is saying that it already has a
bridge setup with planetlab1.tmit.bme.hu. 

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 

And the reason why is because the brokers are each trying to create “duplex”
connections/bridges to each other. So taking out the duplex=”true” attribute
from the network connector elements should do the trick. 

Joe


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


Mime
View raw message