You are viewing a plain text version of this content. The canonical link for it is here.
Posted to users@activemq.apache.org by sambobby <sa...@gmail.com> on 2011/03/11 22:58:12 UTC
Async error occurred Can not remove a consumer from a session not
regd
Client is Spring application running on JBoss server.
Broker is either new fuse broker or apache activemq 5.4.2.
All I am doing is using a failover url in connection factory and just using
one fuse broker running. I just want Spring application reconnect to fuse
broker if broker is restarted.
It does.
But if I restart my spring application, I get to see the following complaint
on broker.
Please suggest , should I further tune broker ? Has this been seen before?
***********************************************
2011-03-11 00:00:02,403 | WARN | Async error occurred:
java.lang.IllegalStateException: Cannot remove a consumer from a session
that had not been registered:
ID:cmlinxapp02.company.com-40623-1299802438786-0:11:1 |
org.apache.activemq.broker.TransportConnection.Service | ActiveMQ Transport:
tcp:///IPADDRESS:43993
java.lang.IllegalStateException: Cannot remove a consumer from a session
that had not been registered:
ID:cmlinxapp02.company.com-40623-1299802438786-0:11:1
at
org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:569)
at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:76)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:310)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:184)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
at
org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)
at
org.apache.activemq.transport.InactivityMonitor.onCommand(InactivityMonitor.java:227)
at
org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)
at
org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:222)
at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:204)
at java.lang.Thread.run(Thread.java:595)
***********************************************************
--
View this message in context: http://activemq.2283324.n4.nabble.com/Async-error-occurred-Can-not-remove-a-consumer-from-a-session-not-regd-tp3349195p3349195.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Async error occurred Can not remove a consumer from a session
not regd
Posted by sambobby <sa...@gmail.com>.
I had come across it and that topic is about network of brokers.
The warning message I am trying to solve is in case of just one broker.
I am using failover protocol just to reconnect to broker in case it goes
down and becomes available later.
But when I restart my client (spring app on j2ee server) I see the warning
message.
--
View this message in context: http://activemq.2283324.n4.nabble.com/Async-error-occurred-Can-not-remove-a-consumer-from-a-session-not-regd-tp3349195p3382996.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Async error occurred Can not remove a consumer from a session
not regd
Posted by hodgesz <ho...@gmail.com>.
Unfortunately we didn't receive any replies. We ended up moving to Kafka
(http://incubator.apache.org/kafka/) which suited our throughput and
availability use cases better.
-Jonathan
--
View this message in context: http://activemq.2283324.n4.nabble.com/Async-error-occurred-Can-not-remove-a-consumer-from-a-session-not-regd-tp3349195p4658786.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Async error occurred Can not remove a consumer from a session
not regd
Posted by patzerbud <pa...@hotmail.com>.
Hi hodgesz:
Did you ever get any useful replies or otherwise fix this problem? I am also
experiencing the exact same thing with a pure master/slave configuration.
TIA,
Mike (aka, patzerbud)
--
View this message in context: http://activemq.2283324.n4.nabble.com/Async-error-occurred-Can-not-remove-a-consumer-from-a-session-not-regd-tp3349195p4658535.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Async error occurred Can not remove a consumer from a session
not regd
Posted by hodgesz <ho...@gmail.com>.
Hi Nag,
I have a very similar problem as the guy above and was wondering if you
think those links can also apply to my problem. I have read Bruce's blogs
but wasn't completely clear what to do. Do I have to setup a network of
brokers and shared database in order to take advantage of those settings
"updateClusterClients", "updateClusterClientsOnRemove"? My use case isn't
as complex so the pure master slave configuration would be better if we can
get past this exception.
I have a Spring web application running in Tomcat 6 when restarted it causes
the following exception in the ActiveMQ logs.
2011-03-21 16:06:01,260 | ERROR | Slave Failed |
org.apache.activemq.broker.ft.MasterBroker | ActiveMQ Transport:
tcp:///x.x.x.x:39216
java.lang.IllegalStateException: Cannot lookup a consumer from a connection
that had not been registered:
ID:ip-x.x.x.x.us-west-1.compute.internal-40565-1300412245896-0:36
at
org.apache.activemq.broker.MapTransportConnectionStateRegister.lookupConnectionState(MapTransportConnectionStateRegister.java:63)
at
org.apache.activemq.broker.TransportConnection.lookupConnectionState(TransportConnection.java:1402)
at
org.apache.activemq.broker.TransportConnection.getConsumerBrokerExchange(TransportConnection.java:1316)
at
org.apache.activemq.broker.TransportConnection.processMessageAck(TransportConnection.java:468)
at org.apache.activemq.command.MessageAck.visit(MessageAck.java:214)
at
org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:311)
at
org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:185)
at
org.apache.activemq.transport.ResponseCorrelator.onCommand(ResponseCorrelator.java:116)
at
org.apache.activemq.transport.TransportFilter.onCommand(TransportFilter.java:69)
at
org.apache.activemq.transport.vm.VMTransport.iterate(VMTransport.java:219)
at
org.apache.activemq.thread.DedicatedTaskRunner.runTask(DedicatedTaskRunner.java:98)
at
org.apache.activemq.thread.DedicatedTaskRunner$1.run(DedicatedTaskRunner.java:36)
I have two ActiveMQ nodes setup in pure master slave configuration
(http://activemq.apache.org/pure-master-slave.html). The following is my
slave activemq.xml configuration.
" producerFlowControl="true" memoryLimit="1mb">
" producerFlowControl="true" memoryLimit="1mb">
Any ideas?
Thanks,
Jonathan
--
View this message in context: http://activemq.2283324.n4.nabble.com/Async-error-occurred-Can-not-remove-a-consumer-from-a-session-not-regd-tp3349195p3398222.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.
Re: Async error occurred Can not remove a consumer from a session
not regd
Posted by nnprasad <NN...@dwd.IN.gov>.
Please have a look at "updateClusterClients", "updateClusterClientsOnRemove"
Bruce Snyder's Blog may also help you::
http://bsnyderblog.blogspot.com/2010/10/new-features-in-activemq-54-automatic.html
New Features in ActiveMQ 5.4.x
http://bsnyderblog.blogspot.com/2010/01/how-to-use-automatic-failover-in.html
How to use Automatic Failover
Thanks
Nag.
--
View this message in context: http://activemq.2283324.n4.nabble.com/Async-error-occurred-Can-not-remove-a-consumer-from-a-session-not-regd-tp3349195p3354024.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.