You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@activemq.apache.org by de...@apache.org on 2010/11/04 12:48:32 UTC
svn commit: r1030888 -
/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
Author: dejanb
Date: Thu Nov 4 11:48:32 2010
New Revision: 1030888
URL: http://svn.apache.org/viewvc?rev=1030888&view=rev
Log:
https://issues.apache.org/activemq/browse/AMQ-3013 - additional fix
Modified:
activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
Modified: activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java
URL: http://svn.apache.org/viewvc/activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java?rev=1030888&r1=1030887&r2=1030888&view=diff
==============================================================================
--- activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java (original)
+++ activemq/trunk/activemq-core/src/main/java/org/apache/activemq/broker/region/TopicRegion.java Thu Nov 4 11:48:32 2010
@@ -130,7 +130,7 @@ public class TopicRegion extends Abstrac
@Override
public void removeSubscription(ConnectionContext context, RemoveSubscriptionInfo info) throws Exception {
SubscriptionKey key = new SubscriptionKey(info.getClientId(), info.getSubscriptionName());
- DurableTopicSubscription sub = durableSubscriptions.get(key);
+ DurableTopicSubscription sub = durableSubscriptions.remove(key);
if (sub == null) {
throw new InvalidDestinationException("No durable subscription exists for: " + info.getSubscriptionName());
}