activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Oscar Pernas <os...@pernas.es>
Subject Re: Problem pure nothing slave-master
Date Wed, 21 Mar 2012 09:44:08 GMT
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 <oscar@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.

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