[
https://issues.apache.org/jira/browse/AMQ-5788?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14575266#comment-14575266
]
Scott Feldstein edited comment on AMQ-5788 at 6/5/15 9:36 PM:
--------------------------------------------------------------
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 see 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}
was (Author: scottmf):
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)
