I think you'll have better luck if the master and slave are connected prior to bringing up the clients.
Joe Breen, Jim wrote: > > Hello, > > I'm trying to get a pure master slave configuration working. Ideally > I'd like to have the brokers be persistent, but I've cut my > configuration back so that it is as simple as possible and pretty much > matches the example master and slave configuration in the test code > base. Still I get errors in the following scenario: > > 1. Start the master broker. > 2. A producer puts a message on a dynamic queue, but there are not yet > any consumers. > 3. The queue and message on the master are visible via JMX. > 4. Start the slave broker. > 5. The logs indicate that the connection between the master and slave > is established, but the queue and message are not visible on the slave > via JMX. > 6. The producer puts a second message on the same dynamic queue. > 7. The queue on the master now shows a QueueSize of 2. The queue is > visible on the slave, but the QueueSize is 0. Also, the slave logs the > following error: > > 2008-01-29 12:18:49,452 [Thread-7 ] INFO MasterConnector > - Slave connection between vm://cpl058#0 and > tcp://cpd040.centerpostcorp.com/172.16.55.56:61616 has been established. > 2008-01-29 12:25:02,939 [: vm://cpl058#1] ERROR Service > - Async error occurred: java.lang.IllegalStateException: Cannot add a > producer to a session that had not been registered: > ID:cpd040-2812-1201630495225-0:0:1 > java.lang.IllegalStateException: Cannot add a producer to a session that > had not been registered: ID:cpd040-2812-1201630495225-0:0:1 > at > org.apache.activemq.broker.TransportConnection.processAddProducer(Transp > ortConnection.java:478) > at > org.apache.activemq.command.ProducerInfo.visit(ProducerInfo.java:105) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnecti > on.java:281) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConn > ection.java:178) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorre > lator.java:100) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter. > java:67) > at > org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:20 > 2) > at > org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunn > er.java:98) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner > .java:36) > 2008-01-29 12:25:03,189 [: vm://cpl058#1] ERROR Service > - Async error occurred: java.lang.NullPointerException > java.lang.NullPointerException > at org.apache.activemq.broker.region.Queue.send(Queue.java:318) > at > org.apache.activemq.broker.region.AbstractRegion.send(AbstractRegion.jav > a:331) > at > org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java:43 > 6) > at > org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.java > :224) > at > org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:125) > at > org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDest > inationBroker.java:95) > at > org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter. > java:135) > at > org.apache.activemq.broker.TransportConnection.processMessage(TransportC > onnection.java:434) > at > org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:6 > 23) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnecti > on.java:281) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConn > ection.java:178) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorre > lator.java:100) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter. > java:67) > at > org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:20 > 2) > at > org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunn > er.java:98) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner > .java:36) > 2008-01-29 12:25:03,193 [: vm://cpl058#1] ERROR Service > - Async error occurred: java.lang.IllegalStateException: Cannot remove a > producer from a session that had not been registered: > ID:cpd040-2812-1201630495225-0:0:1 > java.lang.IllegalStateException: Cannot remove a producer from a session > that had not been registered: ID:cpd040-2812-1201630495225-0:0:1 > at > org.apache.activemq.broker.TransportConnection.processRemoveProducer(Tra > nsportConnection.java:500) > at > org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:66) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnecti > on.java:281) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConn > ection.java:178) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorre > lator.java:100) > at > org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter. > java:67) > at > org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:20 > 2) > at > org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunn > er.java:98) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner > .java:36) > > > The broker config files are attached. The brokers and the producer are > running the 5.1 snapshot from 1/25. Is there something wrong with my > config, or should I open an issue? > > I have tried to get pure master/slave working in 4.1.1, 5.0, and several > 5.1 snapshots, and I always get some sort of error. Has anyone had > success with this feature in any version of ActiveMQ? > > Thanks, > Jim > > > -- View this message in context: http://www.nabble.com/Errors-using-Pure-Master-Slave-tp15166468s2354p15170180.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
