summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorRajith Muditha Attapattu <rajith@apache.org>2010-02-09 00:12:07 +0000
committerRajith Muditha Attapattu <rajith@apache.org>2010-02-09 00:12:07 +0000
commitf46593cf9290715389b57e98a9c9403b6a5a1bb7 (patch)
treeaa9f5370f327186f765ac37e0a49785dae3d3b20
parent6e3ab3d0ccc6ce42dc695e90fae5500cb9a796e9 (diff)
downloadqpid-python-f46593cf9290715389b57e98a9c9403b6a5a1bb7.tar.gz
exclusivity is associated with the Session and not the consumer. Hence session2 needs to be closed to release the lock on the queue
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@907851 13f79535-47bb-0310-9956-ffa450edef68
-rw-r--r--java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java1
1 files changed, 1 insertions, 0 deletions
diff --git a/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java b/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
index fb49704afa..a907e6a29d 100644
--- a/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
+++ b/java/systests/src/main/java/org/apache/qpid/test/unit/topic/DurableSubscriptionTest.java
@@ -162,6 +162,7 @@ public class DurableSubscriptionTest extends QpidTestCase
assertEquals(null, msg);
consumer2.close();
+ session2.close();
producer.send(session1.createTextMessage("B"));