Hi, I am testing this new feature "allowLinkStealing" with ActiveMQ-5.10 broker. I am seeing a weird behavior :
I am seeing that the allowLinkStealing="true" appears to work properly only for the *first* connect with the client ID which is already in used by some other client for the broker; (Similar issue raised in the last post of this thread http://activemq.2283324.n4.nabble.com/MQTT-Link-Stealing-td4682263.html#a4682355 ) After first reconnect, if another client comes and try to connect, broker is not closing the old connection and throwing the below error: [20140926 21:16:28:588 IST (jmsContainer-62) org.springframework.jms.listener.DefaultMessageListenerContainer#handleListenerSetupFailure 666 ERROR] - Setup of JMS message listener invoker failed - trying to recover javax.jms.JMSException: Durable consumer is in use for client: Thest and subscriptionName: ActiveMQConsumer at org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:123) at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:404) at org.apache.activemq.broker.jmx.ManagedRegionBroker.addConsumer(ManagedRegionBroker.java:244) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:97) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:97) at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:97) at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:102) at org.apache.activemq.broker.util.LoggingBrokerPlugin.addConsumer(LoggingBrokerPlugin.java:197) at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:102) at deshaw.tools.jms.ActiveMQLoggingPlugin.addConsumer(ActiveMQLoggingPlugin.java:269) at org.apache.activemq.broker.MutableBrokerFilter.addConsumer(MutableBrokerFilter.java:102) at org.apache.activemq.broker.TransportConnection.processAddConsumer(TransportConnection.java:618) at org.apache.activemq.command.ConsumerInfo.visit(ConsumerInfo.java:349) at org.apache.activemq.broker.TransportConnection.service(TransportConnection.java:294) at org.apache.activemq.broker.TransportConnection$1.onCommand(TransportConnection.java:148) 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:270) at org.apache.activemq.transport.TransportSupport.doConsume(TransportSupport.java:83) at org.apache.activemq.transport.tcp.TcpTransport.doRun(TcpTransport.java:214) at org.apache.activemq.transport.tcp.TcpTransport.run(TcpTransport.java:196) at java.lang.Thread.run(Thread.java:745) Thanks, Anuj -- View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-allowLinkStealing-tp4685916.html Sent from the ActiveMQ - User mailing list archive at Nabble.com.
