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.
