You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by "Breen, Jim" <JB...@west.com> on 2008/01/29 19:46:20 UTC
Errors using Pure Master/Slave
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
RE: Errors using Pure Master/Slave
Posted by ttmdev <jo...@ttmsolutions.com>.
No. Performance-wise the shared approach would be the way to go because the
master does not have to keep the slave sync'd up via a network replication
channel. See this page
http://activemq.apache.org/shared-file-system-master-slave.html
Joe
Breen, Jim wrote:
>
> Do the JDBC and Shared File System flavors of master/slave have the same
> limitation?
>
> -----Original Message-----
> From: ttmdev [mailto:joe.fernandez@ttmsolutions.com]
> 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.
>
>
>
--
View this message in context: http://www.nabble.com/Errors-using-Pure-Master-Slave-tp15166468s2354p15171910.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
RE: Errors using Pure Master/Slave
Posted by "Breen, Jim" <JB...@west.com>.
Do the JDBC and Shared File System flavors of master/slave have the same
limitation?
-----Original Message-----
From: ttmdev [mailto:joe.fernandez@ttmsolutions.com]
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.
Re: Errors using Pure Master/Slave
Posted by ttmdev <jo...@ttmsolutions.com>.
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.
RE: Errors using Pure Master/Slave
Posted by "Breen, Jim" <JB...@west.com>.
I forgot the attachments. Here's the config I'm using.
-----Original Message-----
From: Breen, Jim [mailto:JBreen@west.com]
Sent: Tuesday, January 29, 2008 12:46 PM
To: users@activemq.apache.org
Subject: Errors using Pure Master/Slave
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