activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Marc Tibbitts" <Marc.Tibbi...@paxonix.com>
Subject Master and Slave Errors
Date Tue, 10 Apr 2007 16:12:06 GMT
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>

 

 


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