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.
