activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From neeraj kaushik <neerajkau...@gmail.com>
Subject java.lang.IllegalStateException: Cannot remove a consumer from a session that had not been registered
Date Tue, 24 Mar 2009 12:54:08 GMT

First I would like to explain how I am using request response using Activemq
and NMS.

I create Temporaryqueue and send a message to activemq, there is listener
which listenes queues and replied back to that requestor. After sending
first response listener persist request's corelation id to value in cache
and keep sending responses to this corelationid. So in this case there is
one request for subscription and updates client with responses get.

This was high level view of what I am doing : But if any client disconnect,
listener always try to send msg to queue which is in cache but after some
time everything got hangs. I don't get any exceptions about consumer for
particular has been died. when I go to log of activemq I got lots of below
error. So anybody help me to find out information about queue. I am using
Apache.NMS in C# application.


Exception:

ERROR Service                        - Async error occurred:
java.lang.IllegalStateException: Cannot remove a consumer from a session
that had not been registered: f97c443d-d748-4985-a960-184276cf7bf4:1
INFO   | jvm 1    | 2009/03/24 17:42:51 | java.lang.IllegalStateException:
Cannot remove a consumer from a session that had not been registered:
f97c443d-d748-4985-a960-184276cf7bf4:1
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at
org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:557)
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at
org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:64)
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:305)
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:179)
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:68)
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:143)
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:206)
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:84)
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:203)
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at
org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:185)
INFO   | jvm 1    | 2009/03/24 17:42:51 | 	at java.lang.Thread.run(Unknown
Source)
-- 
View this message in context: http://www.nabble.com/java.lang.IllegalStateException%3A-Cannot-remove-a-consumer-from-a-session-that-had-not-been-registered-tp22679812p22679812.html
Sent from the ActiveMQ - Dev mailing list archive at Nabble.com.


Mime
View raw message