[prev in list] [next in list] [prev in thread] [next in thread]
List: activemq-users
Subject: Re: Network of brokers - already connected
From: toff <toffettg () lu ! unisi ! ch>
Date: 2008-03-31 18:09:00
Message-ID: 16398163.post () talk ! nabble ! com
[Download RAW message or body]
Hi Joe, thank you for your reply. I saw the error message, what I cannot
figure out is why it prints it:
- is it trying to reconnect after being disconnected and failing?
- is it connecting more than once because of wrong configuration?
- how does it decide which client id to use, why?
What I am trying to figure out is whether this is "normal" behavior (doesn't
seem like), or there's a way to avoid it.
Thank you again,
g
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-tp16396907s2354p16398163.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
[prev in list] [next in list] [prev in thread] [next in thread]
Configure |
About |
News |
Add a list |
Sponsored by KoreLogic