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.
