ActiveMQ "allowLinkStealing"

classic Classic list List threaded Threaded
5 messages Options
Reply | Threaded
Open this post in threaded view
|

ActiveMQ "allowLinkStealing"

khandelwalanuj
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
Reply | Threaded
Open this post in threaded view
|

Re: ActiveMQ "allowLinkStealing"

khandelwalanuj
Did anyone get a chance to look at this ?
Reply | Threaded
Open this post in threaded view
|

Re: ActiveMQ "allowLinkStealing"

khandelwalanuj
Ping !!
Reply | Threaded
Open this post in threaded view
|

Re: ActiveMQ "allowLinkStealing"

khandelwalanuj
Any updates here ?
Reply | Threaded
Open this post in threaded view
|

Re: ActiveMQ "allowLinkStealing"

l_evo
This post has NOT been accepted by the mailing list yet.
In reply to this post by khandelwalanuj
same issus here...any solution´╝č