Mailing-List: contact activemq-users-help@geronimo.apache.org; run by ezmlm
Precedence: bulk
Reply-To: activemq-users@geronimo.apache.org
Received-SPF: pass (asf.osuosl.org: local policy)
Message-ID: <44CD99D2.1020002@stc.donpac.ru>
Date: Mon, 31 Jul 2006 09:49:06 +0400
From: Eugene Prokopiev <prokopiev@stc.donpac.ru>
User-Agent: Mozilla/5.0 (X11; U; Linux i686; ru-RU; rv:1.7.2) Gecko/20040808
MIME-Version: 1.0
To: activemq-users@geronimo.apache.org
Subject: Networks of brokers : is it possible to have more than 2 brokers
Content-Type: text/plain; charset=us-ascii; format=flowed
Content-Transfer-Encoding: 7bit

Hi,

I tried to start 3 brokers on different machines. Fist two brokers (m0 
and m1) are connected to each other, but on starting third broker 
(enp-mobile) I got:

INFO - JDK 1.4+ collections available
INFO - Loading XML bean definitions from file 
[/home/john/AMQ/context-amq.xml]
INFO - Bean factory for application context 
[org.springframework.context.support.FileSystemXmlApplicationContext;hashCode=11227341]: 
org.spring
framework.beans.factory.support.DefaultListableBeanFactory defining 
beans [broker]; root of BeanFactory hierarchy
INFO - 1 beans defined in application context 
[org.springframework.context.support.FileSystemXmlApplicationContext;hashCode=11227341]
INFO - Unable to locate MessageSource with name 'messageSource': using 
default [org.springframework.context.support.DelegatingMessageSource@1e0
bc08]
INFO - Unable to locate ApplicationEventMulticaster with name 
'applicationEventMulticaster': using default 
[org.springframework.context.event.S
impleApplicationEventMulticaster@1546e25]
INFO - Pre-instantiating singletons in factory 
[org.springframework.beans.factory.support.DefaultListableBeanFactory 
defining beans [broker]; r
oot of BeanFactory hierarchy]
INFO - Pre-instantiating singletons in factory 
[org.springframework.beans.factory.support.DefaultListableBeanFactory 
defining beans [org.apache
.activemq.broker.TransportConnector,org.apache.activemq.network.DiscoveryNetworkConnector,enp-mobile]; 
root of BeanFactory hierarchy]
INFO - ActiveMQ null JMS Message Broker (localhost) is starting
INFO - For help or more information please see: 
http://incubator.apache.org/activemq/
INFO - Listening for connections at: 
tcp://enp-mobile.ats-network.stc.donpac.ru:32813
WARN - brokerName not set
INFO - Connector tcp://localhost:0 Started
INFO - JMX consoles can connect to 
service:jmx:rmi:///jndi/rmi://localhost:1099/jmxrmi
INFO - Network Connector bridge Started
INFO - ActiveMQ JMS Message Broker (localhost, 
ID:enp-mobile.ats-network.stc.donpac.ru-32810-1154323987617-0:0) started
INFO - Establishing network connection between from 
vm://localhost?network=true to tcp://m0.ats-network.stc.donpac.ru:38702
INFO - binding to broker: localhost
INFO - Connector vm://localhost Started
INFO - Starting a network connection between vm://localhost#0 and 
tcp://null:0 has been established.
INFO - Establishing network connection between from 
vm://localhost?network=true to tcp://m1.ats-network.stc.donpac.ru:51775
INFO - Starting a network connection between vm://localhost#2 and 
tcp://null:0 has been established.
INFO - Network connection between vm://localhost#0 and 
tcp://m0.ats-network.stc.donpac.ru/192.168.46.100:38702(localhost) has 
been established.
INFO - Network connection between vm://localhost#0 and 
tcp://m0.ats-network.stc.donpac.ru/192.168.46.100:38702 shutdown: 
Broker: localhost - Cl
ient: NC_localhost_outboundlocalhost already connected
javax.jms.InvalidClientIDException: Broker: localhost - Client: 
NC_localhost_outboundlocalhost already connected
         at 
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:191)
         at 
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:73)
         at 
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:69)
         at 
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:73)
         at 
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:87)
         at 
org.apache.activemq.broker.AbstractConnection.processAddConnection(AbstractConnection.java:550)
         at 
org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:82)
         at 
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:118)
         at 
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:226)
         at 
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
         at 
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:91)
         at 
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
         at 
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:117)
         at 
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
         at 
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
         at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:127)
         at java.lang.Thread.run(Thread.java:595)
INFO - Network connection between vm://localhost#2 and 
tcp://m1.ats-network.stc.donpac.ru/192.168.46.101:51775 shutdown: 
Broker: localhost - Cl
ient: NC_localhost_outboundlocalhost already connected
javax.jms.InvalidClientIDException: Broker: localhost - Client: 
NC_localhost_outboundlocalhost already connected
         at 
org.apache.activemq.broker.region.RegionBroker.addConnection(RegionBroker.java:191)
         at 
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:73)
         at 
org.apache.activemq.advisory.AdvisoryBroker.addConnection(AdvisoryBroker.java:69)
         at 
org.apache.activemq.broker.BrokerFilter.addConnection(BrokerFilter.java:73)
         at 
org.apache.activemq.broker.MutableBrokerFilter.addConnection(MutableBrokerFilter.java:87)
         at 
org.apache.activemq.broker.AbstractConnection.processAddConnection(AbstractConnection.java:550)
         at 
org.apache.activemq.broker.jmx.ManagedTransportConnection.processAddConnection(ManagedTransportConnection.java:82)
         at 
org.apache.activemq.command.ConnectionInfo.visit(ConnectionInfo.java:118)
         at 
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:226)
         at 
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
         at 
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:91)
         at 
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
         at 
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:117)
         at 
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
         at 
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
         at 
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:127)
         at java.lang.Thread.run(Thread.java:595)
INFO - Shutting down VM connectors for broker: localhost
INFO - Shutting down VM connectors for broker: localhost
ERROR - Failed to start network bridge: java.io.IOException: Transport 
disposed.
java.io.IOException: Transport disposed.
         at 
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:69)
         at 
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
         at 
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:58)
         at 
org.apache.activemq.network.DemandForwardingBridgeSupport.startLocalBridge(DemandForwardingBridgeSupport.java:219)
         at 
org.apache.activemq.network.DemandForwardingBridgeSupport$3.run(DemandForwardingBridgeSupport.java:185)
INFO - Connector vm://localhost Stopped

enp-mobile configuration looks like:

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://activemq.org/config/1.0">

     <broker name="enp-mobile" persistent="false">

         <transportConnectors>
             <transportConnector uri="tcp://localhost:0" 
discoveryUri="multicast://default"/>
         </transportConnectors>

         <networkConnectors>
             <networkConnector uri="multicast://default"/>
         </networkConnectors>

         <persistenceAdapter>
             <memoryPersistenceAdapter/>
         </persistenceAdapter>

     </broker>

</beans>

m0 and m1 configurations are the same as enp-mobile excluding broker name.

What's wrong?

--
Thanks,
Eugene Prokopiev