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 Mon, 31 Mar 2008 17:53:06 GMT

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.


Mime
View raw message