[AMQ-5428] Durable Subscriptions are not being setup while link stealing is happening

• Type: Bug
• Status: Closed
• Priority: Major
• Resolution: Duplicate
• Affects Version/s: 5.11.0
• Fix Version/s: 5.11.0
• Component/s: MQTT

Environment

Activemq 5.11-SNAPSHOT with leveldb and linkstealing enabled.

• Assignee: Unassigned
• Reporter: Netlancer
• Created: 10/Nov/14 02:55
• Updated: 09/Dec/14 16:00
• Resolved: 09/Dec/14 16:00

Description

Intermittently, while an mqtt client is reconnecting, the durable subscriptions are not setup as error is thrown mentioning subscription is still active.

the same can be reproduced by adding sleep into stopAsync method.

ManagedTransportConnection.java

    @Override
    public void stopAsync() {
        if (!isStopping()) {
            synchronized (this) {
                unregisterMBean(byClientIdName);
                unregisterMBean(byAddressName);
                byClientIdName = null;
                byAddressName = null;
            }
        }
        try {
            Thread.sleep(4000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
        super.stopAsync();
    }

stacktrace:

2014-11-10 08:07:06,632 | WARN | Error subscribing to TopicAAA | org.apache.activemq.transport.mqtt.strategy.AbstractMQTTSubscriptionStrategy | ActiveMQ NIO Worker 2
javax.jms.JMSException: Durable consumer is in use for client: Producer and subscriptionName: EXACTLY_ONCE:TopicAAA
at org.apache.activemq.broker.region.TopicRegion.addConsumer(TopicRegion.java:123)[activemq-broker-5.11-SNAPSHOT.jar:5.11-SNAPSHOT]
at org.apache.activemq.broker.region.RegionBroker.addConsumer(RegionBroker.java:427)[activemq-broker-5.11-SNAPSHOT.jar:5.11-SNAPSHOT]
at org.apache.activemq.broker.jmx.ManagedRegionBroker.addConsumer(ManagedRegionBroker.java:244)[activemq-broker-5.11-SNAPSHOT.jar:5.11-SNAPSHOT]
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:102)[activemq-broker-5.11-SNAPSHOT.jar:5.11-SNAPSHOT]
at org.apache.activemq.advisory.AdvisoryBroker.addConsumer(AdvisoryBroker.java:104)[activemq-broker-5.11-SNAPSHOT.jar:5.11-SNAPSHOT]
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:102)[activemq-broker-5.11-SNAPSHOT.jar:5.11-SNAPSHOT]
at org.apache.activemq.broker.BrokerFilter.addConsumer(BrokerFilter.java:102)[activemq-broker-5.11-SNAPSHOT.jar:5.11-SNAPSHOT]

Issue Links

• duplicates: AMQ-5473 Race condition caused by Linkstealing might make durable subs inactive