You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by Matthew Xie <an...@163.com> on 2006/08/08 08:44:54 UTC
A Exception make client hangs up.
I am using ActiveMQ 4.01 and after a long time connecting to the acitvemq
server without sending and recieving message. activemq server throws a
exception and then client langs up. then inspcet the server by JMX, finding
that the consumerCount is "0",
but if the restart AMQ server, the cousumerCount become "1"
the exception messages pasted as follow:
INFO Service - Async error occurred:
java.lang.IllegalStateException: Cannot lookup a connection that had not
been registered: ID:testjlerp-37015-1154330304314-3:15
java.lang.IllegalStateException: Cannot lookup a connection that had not
been registered: ID:testjlerp-37015-1154330304314-3:15
at
org.apache.activemq.broker.AbstractConnection.lookupConnectionState(AbstractConnection.java:241)
at
org.apache.activemq.broker.AbstractConnection.processRemoveConnection(AbstractConnection.java:519)
at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:59)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
at
org.apache.activemq.transport.vm.VMTransport.oneway(VMTransport.java:76)
at
org.apache.activemq.transport.MutexTransport.oneway(MutexTransport.java:44)
at
org.apache.activemq.transport.ResponseCorrelator.oneway(ResponseCorrelator.java:60)
at
org.apache.activemq.network.DemandForwardingBridgeSupport$2.transportInterupted(DemandForwardingBridgeSupport.java:138)
at
org.apache.activemq.transport.TransportFilter.transportInterupted(TransportFilter.java:98)
at
org.apache.activemq.transport.TransportFilter.transportInterupted(TransportFilter.java:98)
at
org.apache.activemq.transport.failover.FailoverTransport.handleTransportFailure(FailoverTransport.java:223)
at
org.apache.activemq.transport.failover.FailoverTransport.access$300(FailoverTransport.java:53)
at
org.apache.activemq.transport.failover.FailoverTransport$1.onException(FailoverTransport.java:111)
at
org.apache.activemq.transport.TransportFilter.onException(TransportFilter.java:94)
at
org.apache.activemq.transport.WireFormatNegotiator.onException(WireFormatNegotiator.java:120)
at
org.apache.activemq.transport.InactivityMonitor.onException(InactivityMonitor.java:149)
at
org.apache.activemq.transport.TransportSupport.onException(TransportSupport.java:100)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:156)
at java.lang.Thread.run(Thread.java:595)
WARN DemandForwardingBridge - Unexpected local command:
ConnectionError {commandId = 2, responseRequired = false, connectionId =
null, exception = java.lang.IllegalStateException: Cannot lookup a
connection that had not been registered:
ID:testjlerp-37015-1154330304314-3:15}
INFO DemandForwardingBridge - Outbound transport to localhost
resumed
INFO DemandForwardingBridge - Network connection between
vm://localhost#0 and tcp://10.1.19.29:61616(localhost) has been established.
INFO Service - Sync error occurred:
java.lang.NullPointerException
java.lang.NullPointerException
at
org.apache.activemq.broker.TransactionBroker.getTransaction(TransactionBroker.java:218)
at
org.apache.activemq.broker.TransactionBroker.commitTransaction(TransactionBroker.java:152)
at
org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:81)
at
org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:81)
at
org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableBrokerFilter.java:94)
at
org.apache.activemq.broker.AbstractConnection.processCommitTransactionOnePhase(AbstractConnection.java:302)
at
org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:98)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
INFO Service - Async error occurred:
java.lang.IllegalStateException: Cannot lookup a consumer from a connection
that had not been registered: ID:testjlerp-47351-1154573492419-0:0
java.lang.IllegalStateException: Cannot lookup a consumer from a connection
that had not been registered: ID:testjlerp-47351-1154573492419-0:0
at
org.apache.activemq.broker.AbstractConnection.lookupConnectionState(AbstractConnection.java:223)
at
org.apache.activemq.broker.AbstractConnection.processMessageAck(AbstractConnection.java:356)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:178)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
INFO Service - Sync error occurred:
java.lang.NullPointerException
java.lang.NullPointerException
at
org.apache.activemq.broker.TransactionBroker.getTransaction(TransactionBroker.java:218)
at
org.apache.activemq.broker.TransactionBroker.commitTransaction(TransactionBroker.java:152)
at
org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:81)
at
org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:81)
at
org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableBrokerFilter.java:94)
at
org.apache.activemq.broker.AbstractConnection.processCommitTransactionOnePhase(AbstractConnection.java:302)
at
org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:98)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
INFO Service - Async error occurred:
java.lang.IllegalStateException: Cannot lookup a consumer from a connection
that had not been registered: ID:testjlerp-47351-1154573492419-0:0
java.lang.IllegalStateException: Cannot lookup a consumer from a connection
that had not been registered: ID:testjlerp-47351-1154573492419-0:0
at
org.apache.activemq.broker.AbstractConnection.lookupConnectionState(AbstractConnection.java:223)
at
org.apache.activemq.broker.AbstractConnection.processMessageAck(AbstractConnection.java:356)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:178)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
INFO Service - Async error occurred:
java.lang.IllegalStateException: Cannot lookup a consumer from a connection
that had not been registered: ID:testjlerp-47351-1154573492419-0:0
java.lang.IllegalStateException: Cannot lookup a consumer from a connection
that had not been registered: ID:testjlerp-47351-1154573492419-0:0
at
org.apache.activemq.broker.AbstractConnection.lookupConnectionState(AbstractConnection.java:223)
at
org.apache.activemq.broker.AbstractConnection.processMessageAck(AbstractConnection.java:356)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:178)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
INFO Service - Sync error occurred:
java.lang.NullPointerException
java.lang.NullPointerException
at
org.apache.activemq.broker.TransactionBroker.getTransaction(TransactionBroker.java:218)
at
org.apache.activemq.broker.TransactionBroker.commitTransaction(TransactionBroker.java:152)
at
org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:81)
at
org.apache.activemq.broker.BrokerFilter.commitTransaction(BrokerFilter.java:81)
at
org.apache.activemq.broker.MutableBrokerFilter.commitTransaction(MutableBrokerFilter.java:94)
at
org.apache.activemq.broker.AbstractConnection.processCommitTransactionOnePhase(AbstractConnection.java:302)
at
org.apache.activemq.command.TransactionInfo.visit(TransactionInfo.java:98)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
INFO Service - Async error occurred:
java.lang.IllegalStateException: Cannot lookup a consumer from a connection
that had not been registered: ID:testjlerp-47351-1154573492419-0:4
java.lang.IllegalStateException: Cannot lookup a consumer from a connection
that had not been registered: ID:testjlerp-47351-1154573492419-0:4
at
org.apache.activemq.broker.AbstractConnection.lookupConnectionState(AbstractConnection.java:223)
at
org.apache.activemq.broker.AbstractConnection.processMessageAck(AbstractConnection.java:356)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:178)
at
org.apache.activemq.broker.AbstractConnection.service(AbstractConnection.java:201)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:62)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:97)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:63)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:114)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:122)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:87)
at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:143)
at java.lang.Thread.run(Thread.java:595)
could anyone do me a favor?
Thx!
Matt.
--
View this message in context: http://www.nabble.com/A-Exception-make-client-hangs-up.-tf2070855.html#a5701227
Sent from the ActiveMQ - User forum at Nabble.com.