activemq-users mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From Matthew Xie <ant_mira...@163.com>
Subject A Exception make client hangs up.
Date Tue, 08 Aug 2006 06:44:54 GMT

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.


Mime
View raw message