diff options
| author | Keith Wall <kwall@apache.org> | 2012-04-20 11:00:13 +0000 |
|---|---|---|
| committer | Keith Wall <kwall@apache.org> | 2012-04-20 11:00:13 +0000 |
| commit | edde8e6a4b8d318007a724b251661f3605e2854a (patch) | |
| tree | 93412857c4ff4ec6ec941f08c783c7ff8e9b2e62 /qpid/java/perftests/src/test | |
| parent | 56d339fbfc0d49cd6b9ce6d2311615fd22b84de3 (diff) | |
| download | qpid-python-edde8e6a4b8d318007a724b251661f3605e2854a.tar.gz | |
QPID-3936: stop queue creator from leaving open session behind
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk@1328318 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'qpid/java/perftests/src/test')
| -rw-r--r-- | qpid/java/perftests/src/test/java/org/apache/qpid/systest/disttest/QpidQueueCreatorTest.java | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/qpid/java/perftests/src/test/java/org/apache/qpid/systest/disttest/QpidQueueCreatorTest.java b/qpid/java/perftests/src/test/java/org/apache/qpid/systest/disttest/QpidQueueCreatorTest.java index 3fa2b9836e..784e43469e 100644 --- a/qpid/java/perftests/src/test/java/org/apache/qpid/systest/disttest/QpidQueueCreatorTest.java +++ b/qpid/java/perftests/src/test/java/org/apache/qpid/systest/disttest/QpidQueueCreatorTest.java @@ -38,7 +38,6 @@ public class QpidQueueCreatorTest extends DistributedTestSystemTestBase private static final Map<String, Object> EMPTY_ATTRIBUTES = Collections.emptyMap(); private QpidQueueCreator _creator; - private Connection _connection; private Session _session; private List<QueueConfig> _configs; private String _queueName; @@ -47,8 +46,8 @@ public class QpidQueueCreatorTest extends DistributedTestSystemTestBase public void setUp() throws Exception { super.setUp(); - _connection = getConnection(); - _session = _connection.createSession(false, Session.AUTO_ACKNOWLEDGE); + Connection connection = getConnection(); + _session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE); _creator = new QpidQueueCreator(); _configs = new ArrayList<QueueConfig>(); _queueName = "direct://amq.direct//" + getTestQueueName(); @@ -60,7 +59,7 @@ public class QpidQueueCreatorTest extends DistributedTestSystemTestBase assertQueueBound(_queueName, false); - _creator.createQueues(_connection, _configs); + _creator.createQueues(_session, _configs); assertQueueBound(_queueName, true); } @@ -73,7 +72,7 @@ public class QpidQueueCreatorTest extends DistributedTestSystemTestBase assertQueueBound(_queueName, false); - _creator.createQueues(_connection, _configs); + _creator.createQueues(_session, _configs); assertQueueBound(_queueName, true); } @@ -84,10 +83,10 @@ public class QpidQueueCreatorTest extends DistributedTestSystemTestBase assertQueueBound(_queueName, false); - _creator.createQueues(_connection, _configs); + _creator.createQueues(_session, _configs); assertQueueBound(_queueName, true); - _creator.deleteQueues(_connection, _configs); + _creator.deleteQueues(_session, _configs); assertQueueBound(_queueName, false); } @@ -100,7 +99,7 @@ public class QpidQueueCreatorTest extends DistributedTestSystemTestBase try { - _creator.deleteQueues(_connection, configs); + _creator.deleteQueues(_session, configs); fail("Exception not thrown"); } catch (DistributedTestException e) |