ActiveMQ "allowLinkStealing"

[khandelwalanuj <kh...@gmail.com>]

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.

Re: ActiveMQ "allowLinkStealing"

[khandelwalanuj <kh...@gmail.com>]

Any updates here ? 



--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-allowLinkStealing-tp4685916p4686169.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ "allowLinkStealing"

[khandelwalanuj <kh...@gmail.com>]

Ping !! 



--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-allowLinkStealing-tp4685916p4686037.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.

Re: ActiveMQ "allowLinkStealing"

[khandelwalanuj <kh...@gmail.com>]

Did anyone get a chance to look at this ? 



--
View this message in context: http://activemq.2283324.n4.nabble.com/ActiveMQ-allowLinkStealing-tp4685916p4685958.html
Sent from the ActiveMQ - User mailing list archive at Nabble.com.