You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Eugene Prokopiev <pr...@stc.donpac.ru> on 2006/07/31 07:49:06 UTC
Networks of brokers : is it possible to have more than 2 brokers
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
Re: Networks of brokers : is it possible to have more than 2 brokers
Posted by Eugene Prokopiev <pr...@stc.donpac.ru>.
> change the:
> <broker name="enp-mobile" persistent="false">
> to
> <broker brokerName="enp-mobile" persistent="false">
Thanks, all works fine
Re: Networks of brokers : is it possible to have more than 2 brokers
Posted by Hiram Chirino <hi...@hiramchirino.com>.
change the:
<broker name="enp-mobile" persistent="false">
to
<broker brokerName="enp-mobile" persistent="false">
On 7/31/06, Eugene Prokopiev <pr...@stc.donpac.ru> wrote:
> 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
>
>
--
Regards,
Hiram
Blog: http://hiramchirino.com