From 1efc01e154874c4a236b9c327ee8f6999393ee09 Mon Sep 17 00:00:00 2001
From: Gordon Sim <gsim@apache.org>
Date: Fri, 22 Jan 2010 19:12:18 +0000
Subject: QPID-2347 broke some java tests; I believe these make incorrect
 assumptions about durable subscriptions and have changed them accordingly.

git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@902231 13f79535-47bb-0310-9956-ffa450edef68
---
 qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java | 1 +
 1 file changed, 1 insertion(+)

(limited to 'qpid/java/client')

diff --git a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
index 8a4fbe5a9b..fc1778f0a1 100644
--- a/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
+++ b/qpid/java/client/src/main/java/org/apache/qpid/client/AMQSession.java
@@ -1664,6 +1664,7 @@ public abstract class AMQSession<C extends BasicMessageConsumer, P extends Basic
         TopicSubscriberAdaptor subscriber = _subscriptions.get(name);
         if (subscriber != null)
         {
+            subscriber.close();
             // send a queue.delete for the subscription
             deleteQueue(AMQTopic.getDurableTopicQueueName(name, _connection));
             _subscriptions.remove(name);
-- 
cgit v1.2.1