[
https://issues.apache.org/jira/browse/AMQ-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14955576#comment-14955576
]
Dhananjay Patkar commented on AMQ-5788:
---------------------------------------
Whats the scenario, in which this exception is thrown?
I am facing the same issue, wherein consumers from 1 host are getting dropped
from 5 to 0 over time. When I look at the broker logs I see these errors
reported against the same host.
{code}
2015-10-08 00:10:25,492 | WARN | Async error occurred: |
org.apache.activemq.broker.TransportConnection.Service | ActiveMQ Transport:
tcp:///host:63772@61616
java.lang.IllegalStateException: Cannot remove session from connection that had
not been registered: ID:host-61408-1444250304231-3:72
at
org.apache.activemq.broker.TransportConnection.processRemoveSession(TransportConnection.java:677)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:74)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:148)[activemq-broker-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)[activemq-client-5.10.0.jar:5.10.0]
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)[activemq-client-5.10.0.jar:5.10.0]
at java.lang.Thread.run(Unknown Source)[:1.6.0_26]
{code}
> 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)
