Do the JDBC and Shared File System flavors of master/slave have the same limitation?
-----Original Message----- From: ttmdev [mailto:[EMAIL PROTECTED] Sent: Tuesday, January 29, 2008 3:51 PM To: users@activemq.apache.org Subject: Re: Errors using Pure Master/Slave 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(Tran > sp > ortConnection.java:478) > at > org.apache.activemq.command.ProducerInfo.visit(ProducerInfo.java:105) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnec > ti > on.java:281) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportCo > nn > ection.java:178) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCor > re > 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(DedicatedTaskRu > nn > er.java:98) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunn > er > .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.j > av > a:331) > at > org.apache.activemq.broker.region.RegionBroker.send(RegionBroker.java: > 43 > 6) > at > org.apache.activemq.broker.TransactionBroker.send(TransactionBroker.ja > va > :224) > at > org.apache.activemq.broker.BrokerFilter.send(BrokerFilter.java:125) > at > org.apache.activemq.broker.CompositeDestinationBroker.send(CompositeDe > st > inationBroker.java:95) > at > org.apache.activemq.broker.MutableBrokerFilter.send(MutableBrokerFilter. > java:135) > at > org.apache.activemq.broker.TransportConnection.processMessage(Transpor > tC > onnection.java:434) > at > org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java > :6 > 23) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnec > ti > on.java:281) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportCo > nn > ection.java:178) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCor > re > 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(DedicatedTaskRu > nn > er.java:98) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunn > er > .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(T > ra > nsportConnection.java:500) > at > org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:66) > at > org.apache.activemq.broker.TransportConnection.service(TransportConnec > ti > on.java:281) > at > org.apache.activemq.broker.TransportConnection$1.onCommand(TransportCo > nn > ection.java:178) > at > org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCor > re > 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(DedicatedTaskRu > nn > er.java:98) > at > org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunn > er > .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-tp15166468s2354p151 70180.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
