activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From ttmdev <joe.fernan...@ttmsolutions.com>
Subject Re: Errors using Pure Master/Slave
Date Tue, 29 Jan 2008 21:51:26 GMT

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.


Mime
View raw message