You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Marc Tibbitts <Ma...@paxonix.com> on 2007/04/10 18:12:06 UTC
Master and Slave Errors
Hello,
This is a first try at configuring pure master slave topology with
ActiveMQ 4.1.
Test message is successfully consumed, however errors reported in both
master and slave logs.
I am keeping activemq.xml very simple and include both configurations
below error messages. What am I missing?
Thanks,
Marc
Error message in Master:
2007/04/10 16:00:27.088]java.lang.AssertionError: Unsupported Method
[2007/04/10 16:00:27.088] at
org.apache.activemq.transport.TransportSupport.request(TransportSupport.
java:71)
[2007/04/10 16:00:27.088] at
org.apache.activemq.transport.TransportFilter.request(TransportFilter.ja
va:88)
[2007/04/10 16:00:27.088] at
org.apache.activemq.transport.TransportFilter.request(TransportFilter.ja
va:88)
[2007/04/10 16:00:27.088] at
org.apache.activemq.transport.MutexTransport.request(MutexTransport.java
:49)
[2007/04/10 16:00:27.088] at
org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBroker.
java:363)
[2007/04/10 16:00:27.088] at
org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.java
:333)
[2007/04/10 16:00:27.088] at
org.apache.activemq.broker.ft.MasterBroker.send(MasterBroker.java:307)
[2007/04/10 16:00:27.088] at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.
java:136)
[2007/04/10 16:00:27.088] at
org.apache.activemq.broker.TransportConnection.processMessage(TransportC
onnection.java:483)
[2007/04/10 16:00:27.088] at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:6
04)
[2007/04/10 16:00:27.088] at
org.apache.activemq.broker.TransportConnection.service(TransportConnecti
on.java:287)
[2007/04/10 16:00:27.088] at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConn
ection.java:178)
[2007/04/10 16:00:27.088] at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.
java:65)
[2007/04/10 16:00:27.088] at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatN
egotiator.java:133)
[2007/04/10 16:00:27.088] at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMoni
tor.java:122)
[2007/04/10 16:00:27.088] at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSuppor
t.java:84)
[2007/04/10 16:00:27.088] at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137
)
[2007/04/10 16:00:27.088] at
java.lang.Thread.run(Thread.java:595)
[2007/04/10 16:00:27.197]Slave Failed
[2007/04/10 16:00:27.197]java.lang.AssertionError: Unsupported Method
[2007/04/10 16:00:27.197] at
org.apache.activemq.transport.TransportSupport.request(TransportSupport.
java:71)
[2007/04/10 16:00:27.197] at
org.apache.activemq.transport.TransportFilter.request(TransportFilter.ja
va:88)
[2007/04/10 16:00:27.197] at
org.apache.activemq.transport.TransportFilter.request(TransportFilter.ja
va:88)
[2007/04/10 16:00:27.197] at
org.apache.activemq.transport.MutexTransport.request(MutexTransport.java
:49)
[2007/04/10 16:00:27.197] at
org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBroker.
java:363)
[2007/04/10 16:00:27.197] at
org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.java
:345)
[2007/04/10 16:00:27.197] at
org.apache.activemq.broker.ft.MasterBroker.acknowledge(MasterBroker.java
:320)
[2007/04/10 16:00:27.197] at
org.apache.activemq.broker.MutableBrokerFilter.acknowledge(MutableBroker
Filter.java:88)
[2007/04/10 16:00:27.197] at
org.apache.activemq.broker.TransportConnection.processMessageAck(Transpo
rtConnection.java:491)
[2007/04/10 16:00:27.197] at
org.apache.activemq.command.MessageAck.visit(MessageAck.java:179)
[2007/04/10 16:00:27.197] at
org.apache.activemq.broker.TransportConnection.service(TransportConnecti
on.java:287)
[2007/04/10 16:00:27.197] at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConn
ection.java:178)
[2007/04/10 16:00:27.197] at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.
java:65)
[2007/04/10 16:00:27.197] at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatN
egotiator.java:133)
[2007/04/10 16:00:27.197] at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMoni
tor.java:122)
[2007/04/10 16:00:27.197] at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSuppor
t.java:84)
[2007/04/10 16:00:27.197] at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137
)
[2007/04/10 16:00:27.197] at
java.lang.Thread.run(Thread.java:595)
Error message is slave:
[2007/04/10 16:00:27.317]2007-04-10 16:00:27,301 [0.2.1.158:61616] DEBUG
Service - Async error occurred:
javax.jms.JMSException: Slave broker out of sync with master: Dispatched
message (ID:SANDBOX-MWTVM1-2290-1176156669853-0:8:1:1:1) was not in the
pending list:
org.apache.activemq.broker.region.cursors.VMPendingMessageCursor@1ce00b4
[2007/04/10 16:00:27.317]javax.jms.JMSException: Slave broker out of
sync with master: Dispatched message
(ID:SANDBOX-MWTVM1-2290-1176156669853-0:8:1:1:1) was not in the pending
list:
org.apache.activemq.broker.region.cursors.VMPendingMessageCursor@1ce00b4
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.region.PrefetchSubscription.processMessageDis
patchNotification(PrefetchSubscription.java:153)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.region.AbstractRegion.processDispatchNotifica
tion(AbstractRegion.java:331)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.region.RegionBroker.processDispatchNotificati
on(RegionBroker.java:528)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.BrokerFilter.processDispatchNotification(Brok
erFilter.java:200)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.BrokerFilter.processDispatchNotification(Brok
erFilter.java:200)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.BrokerFilter.processDispatchNotification(Brok
erFilter.java:200)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.MutableBrokerFilter.processDispatchNotificati
on(MutableBrokerFilter.java:208)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.TransportConnection.processMessageDispatchNot
ification(TransportConnection.java:514)
[2007/04/10 16:00:27.317] at
org.apache.activemq.command.MessageDispatchNotification.visit(MessageDis
patchNotification.java:76)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.TransportConnection.service(TransportConnecti
on.java:293)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConn
ection.java:184)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorre
lator.java:95)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.
java:65)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.vm.VMTransport.syncOneWay(VMTransport.java
:96)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:83)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:
47)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelat
or.java:60)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.ft.MasterConnector.serviceRemoteCommand(Maste
rConnector.java:236)
[2007/04/10 16:00:27.317] at
org.apache.activemq.broker.ft.MasterConnector$2.onCommand(MasterConnecto
r.java:126)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorre
lator.java:95)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.
java:65)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatN
egotiator.java:133)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMoni
tor.java:122)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSuppor
t.java:84)
[2007/04/10 16:00:27.317] at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137
)
[2007/04/10 16:00:27.317] at
java.lang.Thread.run(Thread.java:595)
Master activemq.xml:
<beans>
<broker useJmx="false" xmlns="http://activemq.org/config/1.0">
<transportConnectors>
<transportConnector uri="tcp://sandbox-mwtvm1:61616" />
</transportConnectors>
</broker>
</beans>
Slave activemq.xml:
<beans>
<broker masterConnectorURI="tcp://sandbox-mwtvm1:61616"
shutdownOnMasterFailure="false"
useJmx="false" xmlns="http://activemq.org/config/1.0">
<transportConnectors>
<transportConnector uri="tcp://sandbox-mt:61616" />
</transportConnectors>
</broker>
</beans>