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();
     }
 
 }