1 Reply Latest reply on Mar 1, 2012 8:05 AM by Jakub Korab

    Cannot remove a consumer that had not been registered

    Thomas Peters Newbie

      I am using Fuse SMX 4.4.1 & ActiveMQ 5.5.1 (both downloaded from FuseSource). I am adding transactional client. When I generate exception in the route, it should keep the message on the source queue. However, message got lost and I see the following in the ActiveMQ console:

       

      WARN | Async error occurred: java.lang.IllegalStateException: Cannot remove a consumer that had not been registered: ID:tp-49921-1330369556663-18:1:1:25

      ava.lang.IllegalStateException: Cannot remove a consumer that had not been registered: ID:tp-49921-1330369556663-18:1:1:25

             at org.apache.activemq.broker.TransportConnection.processRemoveConsumer(TransportConnection.java:583)

             at org.apache.activemq.command.RemoveInfo.visit(RemoveInfo.java:76)

             at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:318)

             at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:181)

             at org.apache.activemq.transport.MutexTransport.onCommand(MutexTransport.java:50)

             at org.apache.activemq.transport.WireFormatNegotiator.onCommand(WireFormatNegotiator.java:113)

             at org.apache.activemq.transport.AbstractInactivityMonitor.onCommand(AbstractInactivityMonitor.java:229)

             at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83)

             at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:221)

             at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:203)

             at java.lang.Thread.run(Thread.java:662)