[
https://issues.apache.org/jira/browse/AMQ-3373?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13438546#comment-13438546
]
Vitali Kviatkouski commented on AMQ-3373:
-----------------------------------------
Reproducable on ActiveMQ 5.6.0
Seems this happens because it is expected that there is consumer connection on
slave. And when we follow this flow:
1. Start master
2. Start slave
3. Start consumers (consuming app)
everything works fine as consumer connections are replicated to slave only when
they are created.
But when we restart slave, consumer connections on master are untouched, so
they are not replicated to slave.
My proposal is to replicate active consumer connections on slave when slave
connects to master.
> Pure master/slave connection state error on the master machine.
> ----------------------------------------------------------------
>
> Key: AMQ-3373
> URL: https://issues.apache.org/jira/browse/AMQ-3373
> Project: ActiveMQ
> Issue Type: Bug
> Components: Broker
> Affects Versions: 5.5.0
> Environment: CentOS 5.6 - x86_64 - 2GB RAM
> Reporter: Jose Guerra
>
> I added this annoying exception thrown by the master ActiveMQ 5.5 when it's
> connected as pure master/slave. The slave doesn't complain at all and the
> failover is performed correctly.
> Thanks
> 2011-06-15 23:18:47,368 | ERROR | Slave Failed |
> org.apache.activemq.broker.ft.MasterBroker | VMTransport: vm://localhost#1
> java.lang.IllegalStateException: Cannot lookup a consumer from a connection
> that had not been registered: ID:ntcs-amq1-53476-1308056848065-2:1
> at
> org.apache.activemq.broker.MapTransportConnectionStateRegister.lookupConnectionState(MapTransportConnectionStateRegister.java:67)
> at
> org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1423)
> at
> org.apache.activemq.broker.TransportConnection.getConsumerBrokerExchange(TransportConnection.java:1337)
> at
> org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:464)
> at org.apache.activemq.command.MessageAck.visit(MessageAck.java:229)
> at
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
> at
> org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:218)
> at
> org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104)
> at
> org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42)
> 2011-06-15 23:18:47,392 | ERROR | Slave Failed |
> org.apache.activemq.broker.ft.MasterBroker | VMTransport: vm://localhost#3
> java.lang.IllegalStateException: Cannot lookup a consumer from a connection
> that had not been registered: ID:ntcs-amq1-53476-1308056848065-2:2
> at
> org.apache.activemq.broker.MapTransportConnectionStateRegister.lookupConnectionState(MapTransportConnectionStateRegister.java:67)
> at
> org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1423)
> at
> org.apache.activemq.broker.TransportConnection.getConsumerBrokerExchange(TransportConnection.java:1337)
> at
> org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:464)
> at org.apache.activemq.command.MessageAck.visit(MessageAck.java:229)
> at
> org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:306)
> at
> org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
> at
> org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
> at
> org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
> at
> org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:218)
> at
> org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:104)
> at
> org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:42)
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
