activemq-issues mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Scott Feldstein (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (AMQ-5788) Failover issue: IllegalStateException: Cannot remove session | producer from connection that had not been registered
Date Fri, 05 Jun 2015 21:37:00 GMT

    [ https://issues.apache.org/jira/browse/AMQ-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14575266#comment-14575266
] 

Scott Feldstein commented on AMQ-5788:
--------------------------------------

I'm seeing the same issue using the replicatedLevelDB on activemq 5.11.1.  The client uses
spring-boot with apache camel version 2.15.2

When this occurs it appears that activemq will not process anymore requests from the origin
host.  Not sure if this is the root cause of why the cluster won't process requests from this
host, but I do this this message pop up.  All other hosts appear to work fine.  Unfortunately
I don't know how to reproduce at this time.

Here is the stack:

{code}
activemq 2015-06-05 13:28:45,798 WARN  [ActiveMQ Transport: tcp:///10.1.1.244:47420@61616]
[org.apache.activemq.broker.TransportConnection.Service@312] Async error occurred:
java.lang.IllegalStateException: Cannot remove session from connection that had not been registered:
ID:frontend.localdomain-33086-1433535426896-1:2
        at org.apache.activemq.broker.TransportConnection.processRemoveSession(TransportConnection.java:722)
        at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:74)
        at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:334)
        at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:188)
        at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)
        at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
        at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:270)
        at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
        at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214)
        at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196)
        at java.lang.Thread.run(Thread.java:745)
{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