Hi all, Sorry for being impatient but in documentation there is only one parameter to change in slave and I dont know if there is any trick to make it runs.
When I send a message to the master broker, in the slave broker I could see: DEBUG | Transport failed: org.apache.activemq.transport.TransportDisposedIOException: Transport disposed. org.apache.activemq.transport.TransportDisposedIOException: Transport disposed. ERROR | Network connection between vm://slave#0 and tcp:///127.0.0.1:61616shutdown: Peer (vm://slave#1) disposed. | org.apache.activemq.broker.ft.MasterConnector | ActiveMQ Transport: tcp:/// 127.0.0.1:61616 ERROR | Network connection between vm://slave#0 and tcp:///127.0.0.1:61616shutdown: Peer (vm://slave#1) disposed. org.apache.activemq.transport.TransportDisposedIOException: Peer (vm://slave#1) disposed. WARN | Master Failed - starting all connectors INFO | Listening for connections at: tcp://localhost:61620 INFO | Connector openwire Started I could see some issues in jira but Im not sure, any advice? thanks! El 20 de marzo de 2012 14:33, Oscar Pernas <os...@pernas.es> escribió: > Hi all, > > Im having a problem and I dont know how to resolve it. I have a broker > called master, that doesnt have any changes between the file to make a > cluster. I have a slave node that contains this (only thing that changed is > bold) > > <beans > xmlns="http://www.springframework.org/schema/beans"; > xmlns:amq="http://activemq.apache.org/schema/core"; > xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"; > xsi:schemaLocation="http://www.springframework.org/schema/beans > http://www.springframework.org/schema/beans/spring-beans-2.0.xsd > http://activemq.apache.org/schema/core > http://activemq.apache.org/schema/core/activemq-core.xsd";> > <bean > class="org.springframework.beans.factory.config.PropertyPlaceholderConfigurer"> > <property name="locations"> > <value>file:${activemq.base}/conf/credentials.properties</value> > </property> > </bean> > <broker xmlns="http://activemq.apache.org/schema/core"; * > masterConnectorURI="tcp://192.168.56.101:61620" > **shutdownOnMasterFailure="false" waitForSlave="true" brokerName="slave" > *dataDirectory="${activemq.base}/data" > > <destinationPolicy> > <policyMap> > <policyEntries> > <policyEntry topic=">" producerFlowControl="false" > memoryLimit="300 mb"> > <deadLetterStrategy> > <sharedDeadLetterStrategy processExpired="false" /> > </deadLetterStrategy> > <pendingDurableSubscriberPolicy> > <fileDurableSubscriberCursor/> > </pendingDurableSubscriberPolicy> > <pendingSubscriberPolicy> > <fileCursor /> > </pendingSubscriberPolicy> > </policyEntry> > <policyEntry queue=">" producerFlowControl="false" > memoryLimit="300 mb"> > <deadLetterStrategy> > <sharedDeadLetterStrategy processExpired="false" /> > </deadLetterStrategy> > <pendingQueuePolicy> > <vmQueueCursor/> > </pendingQueuePolicy> > </policyEntry> > </policyEntries> > </policyMap> > </destinationPolicy> > <managementContext> > <managementContext createConnector="false"/> > </managementContext> > <persistenceAdapter> > <kahaDB directory="${activemq.base}/data/kahadb"/> > </persistenceAdapter> > <systemUsage> > <systemUsage> > <memoryUsage> > <memoryUsage limit="1 gb"/> > </memoryUsage> > <storeUsage> > <storeUsage limit="10 gb"/> > </storeUsage> > <tempUsage> > <tempUsage limit="500 mb"/> > </tempUsage> > </systemUsage> > </systemUsage> > <transportConnectors> > <transportConnector name="openwire" uri="tcp://0.0.0.0:61616" > /> > </transportConnectors> > > </broker> > <import resource="jetty.xml"/> > </beans> > > The master configuration file is the same (without bold lines). When I > startup the master, and after the slave, I can see a trace (slave is > attached)... everything looks fine. But, at the moment of I start to send > messages to the master, the slave prints a trace like this: > > ERROR | Network connection between vm://slave#0 and tcp:/// > 192.168.56.101:61620 shutdown: Peer (vm://slave#1) disposed. > org.apache.activemq.transport.TransportDisposedIOException: Peer > (vm://slave#1) disposed. > at > org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:89) > at > org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40) > at > org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60) > at > org.apache.activemq.broker.ft.MasterConnector.serviceRemoteCommand(MasterConnector.java:270) > at > org.apache.activemq.broker.ft.MasterConnector$2.onCommand(MasterConnector.java:138) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69) > at > org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) > at > org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227) > at > org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) > at > org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:220) > at > org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:202) > at java.lang.Thread.run(Unknown Source) > WARN | Master Failed - starting all connectors > DEBUG | Transport failed: > org.apache.activemq.transport.TransportDisposedIOException: Transport > disposed. > org.apache.activemq.transport.TransportDisposedIOException: Transport > disposed. > at > org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76) > at > org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:40) > at > org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60) > at > org.apache.activemq.broker.TransportConnection.dispatch(TransportConnection.java:1270) > at > org.apache.activemq.broker.TransportConnection.processDispatch(TransportConnection.java:815) > at > org.apache.activemq.broker.TransportConnection.dispatchSync(TransportConnection.java:775) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:181) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69) > at > org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:218) > at > org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42) > > > what could be the reason?????? thanks in advance > > > -- > Óscar Pernas Plaza. > -- Óscar Pernas Plaza.
