You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by kieran1 <KM...@herzumsoftware.com> on 2006/11/28 21:54:51 UTC

4.1 Snapshot Pure Master Slave -- unsupported method

I am trying to test pure master/slave with the Nov. 10 snapshot of 4.1.  My
master and slave configurations are attached.  I am working with the
configuration instructions at:
http://www.activemq.org/site/masterslave.html

My master broker is running at localhost:61616, and my slave broker is at
localhost:61617.  My brokers and clients are all using only the Nov. 10
snapshot code. My producer and consumer
http://www.nabble.com/file/4321/activemq.xml activemq.xml 
http://www.nabble.com/file/4322/activemq.xml activemq.xml  are connecting to
the cluster with this URL:

failover:(tcp://localhost:61616,tcp://localhost:61617)?randomize=false&initialReconnectDelay=1000&maxReconnectAttempts=3

The master and slave brokers both startup without exceptions and the slave
properly attaches to the master.  

The first problem I encounter is when my producer tries to send a message on
the master broker.  The master gets the following exception on every message
and no messages are replicated to the slave:

ERROR MasterBroker                   - Slave Failed
java.lang.AssertionError: Unsupported Method
        at
org.apache.activemq.transport.TransportSupport.request(TransportSupport.java:71)
        at
org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88)
        at
org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88)
        at
org.apache.activemq.transport.MutexTransport.request(MutexTransport.java:49)
        at
org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBroker.java:363)
        at
org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.java:333)
        at
org.apache.activemq.broker.ft.MasterBroker.send(MasterBroker.java:307)
        at
org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:136)
        at
org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:480)
        at
org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:604)
        at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:284)
        at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:177)
        at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
        at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:133)
        at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
        at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
        at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
        at java.lang.Thread.run(Thread.java:595)

Any suggestions?  Thanks in advance.
Kieran
http://www.nabble.com/file/4321/master.activemq.xml master.activemq.xml 
http://www.nabble.com/file/4322/slave.activemq.xml slave.activemq.xml 
-- 
View this message in context: http://www.nabble.com/4.1-Snapshot-Pure-Master-Slave----unsupported-method-tf2720929.html#a7587526
Sent from the ActiveMQ - User mailing list archive at Nabble.com.


Re: 4.1 Snapshot Pure Master Slave -- unsupported method

Posted by Marlon Santos <ms...@exist.com>.
Hi, 

Well it looks like a bug.  I raised an issue an you can follow the progress
at this url https://issues.apache.org/activemq/browse/AMQ-1079..

Regards,
Marlon



kieran1 wrote:
> 
> I am trying to test pure master/slave with the Nov. 10 snapshot of 4.1. 
> My master and slave configurations are attached.  I am working with the
> configuration instructions at:
> http://www.activemq.org/site/masterslave.html
> 
> My master broker is running at localhost:61616, and my slave broker is at
> localhost:61617.  My brokers and clients are all using only the Nov. 10
> snapshot code. My producer and consumer
> http://www.nabble.com/file/4321/activemq.xml activemq.xml 
> http://www.nabble.com/file/4322/activemq.xml activemq.xml  are connecting
> to the cluster with this URL:
> 
> failover:(tcp://localhost:61616,tcp://localhost:61617)?randomize=false&initialReconnectDelay=1000&maxReconnectAttempts=3
> 
> The master and slave brokers both startup without exceptions and the slave
> properly attaches to the master.  
> 
> The first problem I encounter is when my producer tries to send a message
> on the master broker.  The master gets the following exception on every
> message and no messages are replicated to the slave:
> 
> ERROR MasterBroker                   - Slave Failed
> java.lang.AssertionError: Unsupported Method
>         at
> org.apache.activemq.transport.TransportSupport.request(TransportSupport.java:71)
>         at
> org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88)
>         at
> org.apache.activemq.transport.TransportFilter.request(TransportFilter.java:88)
>         at
> org.apache.activemq.transport.MutexTransport.request(MutexTransport.java:49)
>         at
> org.apache.activemq.broker.ft.MasterBroker.sendSyncToSlave(MasterBroker.java:363)
>         at
> org.apache.activemq.broker.ft.MasterBroker.sendToSlave(MasterBroker.java:333)
>         at
> org.apache.activemq.broker.ft.MasterBroker.send(MasterBroker.java:307)
>         at
> org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter.java:136)
>         at
> org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:480)
>         at
> org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:604)
>         at
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:284)
>         at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:177)
>         at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:65)
>         at
> org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:133)
>         at
> org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
>         at
> org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
>         at
> org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:137)
>         at java.lang.Thread.run(Thread.java:595)
> 
> Any suggestions?  Thanks in advance.
> Kieran
>  http://www.nabble.com/file/4321/master.activemq.xml master.activemq.xml 
> http://www.nabble.com/file/4322/slave.activemq.xml slave.activemq.xml 
> 

-- 
View this message in context: http://www.nabble.com/4.1-Snapshot-Pure-Master-Slave----unsupported-method-tf2720929.html#a7615012
Sent from the ActiveMQ - User mailing list archive at Nabble.com.