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)