summaryrefslogtreecommitdiff
path: root/qpid/java
diff options
context:
space:
mode:
authorRobert Gemmell <robbie@apache.org>2010-02-25 17:18:25 +0000
committerRobert Gemmell <robbie@apache.org>2010-02-25 17:18:25 +0000
commit4021ccbe751770185c57e0d35a4c979c0c2a98cf (patch)
treea893802d257c9cf6158f3057a0ca8694ea493275 /qpid/java
parentd6d234e73dbcface912acbf9a34d3e1964042faf (diff)
downloadqpid-python-4021ccbe751770185c57e0d35a4c979c0c2a98cf.tar.gz
QPID-2417: unsubscribe the durable subscriptions when done to delete the queues
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@916356 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java')
-rw-r--r--qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java5
1 files changed, 5 insertions, 0 deletions
diff --git a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
index e14d4011a3..970b08f629 100644
--- a/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
+++ b/qpid/java/systests/src/main/java/org/apache/qpid/server/queue/TimeToLiveTest.java
@@ -305,6 +305,7 @@ public class TimeToLiveTest extends QpidTestCase
Assert.assertFalse("Final message has first set.", receivedSecond.getBooleanProperty("first"));
Assert.assertEquals("Final message has incorrect TTL.", 0L, receivedSecond.getLongProperty("TTL"));
+ clientSession.unsubscribe(getTestQueueName());
clientConnection.close();
producerConnection.close();
@@ -360,6 +361,10 @@ public class TimeToLiveTest extends QpidTestCase
producer.close();
producerSession.close();
producerConnection.close();
+
+ clientSession.unsubscribe("MyDurableTTLSubscription");
+ clientSession.close();
+ clientConnection.close();
}
}