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 | 482c85d85eff731abeb5b3f0fe31789fffa7735a (patch) | |
| tree | 0c5926ddcd4241ca2afaa1617ea4028ac35623b1 /java/perftests/src/test | |
| parent | fe501062df68c33d12778f5ce91ff1c2eed24932 (diff) | |
| download | qpid-python-482c85d85eff731abeb5b3f0fe31789fffa7735a.tar.gz | |
QPID-3936: stop queue creator from leaving open session behind
git-svn-id: https://svn.apache.org/repos/asf/qpid/trunk/qpid@1328318 13f79535-47bb-0310-9956-ffa450edef68
Diffstat (limited to 'java/perftests/src/test')
| -rw-r--r-- | java/perftests/src/test/java/org/apache/qpid/systest/disttest/QpidQueueCreatorTest.java | 15 |
1 files changed, 7 insertions, 8 deletions
diff --git a/java/perftests/src/test/java/org/apache/qpid/systest/disttest/QpidQueueCreatorTest.java b/java/perftests/src/test/java/org/apache/qpid/systest/disttest/QpidQueueCreatorTest.java index 3fa2b9836e..784e43469e 100644 --- a/java/perftests/src/test/java/org/apache/qpid/systest/disttest/QpidQueueCreatorTest.java +++ b/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) |