activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Oscar Pernas <os...@pernas.es>
Subject Problem pure nothing slave-master
Date Tue, 20 Mar 2012 13:33:55 GMT
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.

Mime
  • Unnamed multipart/alternative (inline, None, 0 bytes)
View raw message