activemq-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "AR (JIRA)" <j...@apache.org>
Subject [jira] [Commented] (AMQ-5428) Durable Subscriptions are not being setup while link stealing is happening
Date Wed, 03 Dec 2014 18:23:13 GMT

    [ https://issues.apache.org/jira/browse/AMQ-5428?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14233282#comment-14233282
] 

AR commented on AMQ-5428:
-------------------------

I think this is related to https://issues.apache.org/jira/browse/AMQ-5473. Can you verify?

> 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