You are viewing a plain text version of this content. The canonical link for it is here.
Posted to issues@activemq.apache.org by "Timothy Bish (JIRA)" <ji...@apache.org> on 2015/08/13 15:59:45 UTC
[jira] [Closed] (AMQ-5788) Failover issue: IllegalStateException:
Cannot remove session | producer from connection that had not been
registered
[ https://issues.apache.org/jira/browse/AMQ-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Timothy Bish closed AMQ-5788.
-----------------------------
Resolution: Incomplete
Not test case provided to reproduce.
> Failover issue: IllegalStateException: Cannot remove session | producer from connection that had not been registered
> --------------------------------------------------------------------------------------------------------------------
>
> Key: AMQ-5788
> URL: https://issues.apache.org/jira/browse/AMQ-5788
> Project: ActiveMQ
> Issue Type: Bug
> Reporter: Endre Stølsvik
>
> I am evidently having major problems with failover TCP transport, getting these types of exceptions after a master has shut down and another of the "hot standby" (using JDBC "Cluster" configuration) takes over (aquires the lease):
> {code}
> 2015-05-20 16:11:51,186 [ActiveMQ Transport: tcp:///127.0.0.1:50160@61617] DEBUG o.a.a.b.TransportConnection.Service - Error occured while processing async command: RemoveInfo {commandId = 274, responseRequired = false, objectId = ID:SVGD122-63456-1432130352376-1:2:136, lastDeliveredSequenceId = 0}, exception: java.lang.IllegalStateException: Cannot remove session from connection that had not been registered: ID:SVGD122-63456-1432130352376-1:2
> java.lang.IllegalStateException: Cannot remove session from connection that had not been registered: ID:SVGD122-63456-1432130352376-1:2
> at org.apache.activemq.broker.TransportConnection.processRemoveSession(TransportConnection.java:722) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:74) ~[activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188) [activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) [activemq-client-5.11.1.jar:5.11.1]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_25]
> 2015-05-20 16:11:51,186 [ActiveMQ Transport: tcp:///127.0.0.1:50160@61617] WARN o.a.a.b.TransportConnection.Service - Async error occurred:
> java.lang.IllegalStateException: Cannot remove session from connection that had not been registered: ID:SVGD122-63456-1432130352376-1:2
> at org.apache.activemq.broker.TransportConnection.processRemoveSession(TransportConnection.java:722) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:74) ~[activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188) [activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) [activemq-client-5.11.1.jar:5.11.1]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_25]
> {code}
> {code}
> 2015-05-20 16:11:47,280 [ActiveMQ Transport: tcp:///127.0.0.1:50146@61617] DEBUG o.a.a.b.TransportConnection.Service - Error occured while processing async command: ActiveMQMessage {commandId = 177, responseRequired = false, messageId = ID:SVGD122-63456-1432130352376-1:1:1:1:89, originalDestination = null, originalTransactionId = null, producerId = ID:SVGD122-63456-1432130352376-1:1:1:1, destination = queue://ActiveMQ.Statistics.Broker, transactionId = null, expiration = 0, timestamp = 1432131107279, arrival = 0, brokerInTime = 0, brokerOutTime = 0, correlationId = null, replyTo = topic://ABC.JWActiveMQ.StatisticsMessage, persistent = false, type = null, priority = 4, groupID = null, groupSequence = 0, targetConsumerId = null, compressed = false, userID = null, content = null, marshalledProperties = null, dataStructure = null, redeliveryCounter = 0, size = 0, properties = null, readOnlyProperties = false, readOnlyBody = false, droppable = false, jmsXGroupFirstForConsumer = false}, exception: java.lang.IllegalStateException: Cannot lookup a producer from a connection that had not been registered: ID:SVGD122-63456-1432130352376-1:1
> java.lang.IllegalStateException: Cannot lookup a producer from a connection that had not been registered: ID:SVGD122-63456-1432130352376-1:1
> at org.apache.activemq.broker.SingleTransportConnectionStateRegister.lookupConnectionState(SingleTransportConnectionStateRegister.java:93) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1599) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection.getProducerBrokerExchange(TransportConnection.java:1469) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:539) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768) ~[activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188) [activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) [activemq-client-5.11.1.jar:5.11.1]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_25]
> 2015-05-20 16:11:47,281 [ActiveMQ Transport: tcp:///127.0.0.1:50146@61617] WARN o.a.a.b.TransportConnection.Service - Async error occurred:
> java.lang.IllegalStateException: Cannot lookup a producer from a connection that had not been registered: ID:SVGD122-63456-1432130352376-1:1
> at org.apache.activemq.broker.SingleTransportConnectionStateRegister.lookupConnectionState(SingleTransportConnectionStateRegister.java:93) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1599) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection.getProducerBrokerExchange(TransportConnection.java:1469) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection.processMessage(TransportConnection.java:539) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.command.ActiveMQMessage.visit(ActiveMQMessage.java:768) ~[activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334) ~[activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188) [activemq-broker-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214) [activemq-client-5.11.1.jar:5.11.1]
> at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) [activemq-client-5.11.1.jar:5.11.1]
> at java.lang.Thread.run(Thread.java:745) [na:1.8.0_25]
> {code}
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)