activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Netlancer (JIRA)" <j...@apache.org>
Subject [jira] [Created] (AMQ-5428) Durable Subscriptions are not being setup while link stealing is happening
Date Mon, 10 Nov 2014 02:56:33 GMT
Netlancer created AMQ-5428:
------------------------------

             Summary: Durable Subscriptions are not being setup while link stealing is happening
                 Key: AMQ-5428
                 URL: https://issues.apache.org/jira/browse/AMQ-5428
             Project: ActiveMQ
          Issue Type: Bug
          Components: MQTT
    Affects Versions: 5.11.0
         Environment: Activemq 5.11-SNAPSHOT with leveldb and linkstealing enabled.
            Reporter: Netlancer


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.
{code:title=ManagedTransportConnection.java|borderStyle=solid}
    @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();
    }
{code}

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]




--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Mime
View raw message