activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Dhananjay Patkar (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (AMQ-5788) Failover issue: IllegalStateException: Cannot remove session | producer from connection that had not been registered
Date Tue, 13 Oct 2015 20:26:06 GMT

    [ 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)

Mime
View raw message