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.
