activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From toff <toffe...@lu.unisi.ch>
Subject Network of brokers - already connected
Date Mon, 31 Mar 2008 16:27:18 GMT

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.


Mime
View raw message