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

3 files changed, 11 insertions, 24 deletions

diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ControllerJmsDelegate.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ControllerJmsDelegate.java
index 3bf8e6ff4a..69da409be5 100644
--- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ControllerJmsDelegate.java
+++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/ControllerJmsDelegate.java
@@ -190,12 +190,12 @@ public class ControllerJmsDelegate
 
     public void createQueues(List<QueueConfig> queues)
     {
-        _queueCreator.createQueues(_connection, queues);
+        _queueCreator.createQueues(_session, queues);
     }
 
     public void deleteQueues(List<QueueConfig> queues)
     {
-        _queueCreator.deleteQueues(_connection, queues);
+        _queueCreator.deleteQueues(_session, queues);
     }
 
     public void addCommandListener(CommandListener commandListener)
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidQueueCreator.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidQueueCreator.java
index 6b21181b2a..912ce54495 100644
--- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidQueueCreator.java
+++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QpidQueueCreator.java
@@ -20,8 +20,6 @@ package org.apache.qpid.disttest.jms;
 
 import java.util.List;
 
-import javax.jms.Connection;
-import javax.jms.JMSException;
 import javax.jms.Session;
 
 import org.apache.qpid.client.AMQDestination;
@@ -39,22 +37,22 @@ public class QpidQueueCreator implements QueueCreator
     private static final FieldTable EMPTY_QUEUE_BIND_ARGUMENTS = new FieldTable();
 
     @Override
-    public void createQueues(Connection connection, List<QueueConfig> configs)
+    public void createQueues(Session session, List<QueueConfig> configs)
     {
-        AMQSession<?, ?> session = createSession(connection);
+        AMQSession<?, ?> amqSession = (AMQSession<?, ?>)session;
         for (QueueConfig queueConfig : configs)
         {
-            createQueue(session, queueConfig);
+            createQueue(amqSession, queueConfig);
         }
     }
 
     @Override
-    public void deleteQueues(Connection connection, List<QueueConfig> configs)
+    public void deleteQueues(Session session, List<QueueConfig> configs)
     {
-        AMQSession<?, ?> session = createSession(connection);
+        AMQSession<?, ?> amqSession = (AMQSession<?, ?>)session;
         for (QueueConfig queueConfig : configs)
         {
-            deleteQueue(session, queueConfig);
+            deleteQueue(amqSession, queueConfig);
         }
     }
 
@@ -96,15 +94,4 @@ public class QpidQueueCreator implements QueueCreator
         }
     }
 
-    private AMQSession<?, ?> createSession(Connection connection)
-    {
-        try
-        {
-            return (AMQSession<?, ?>) connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
-        }
-        catch (JMSException e)
-        {
-            throw new DistributedTestException("Failed to create session!", e);
-        }
-    }
 }
diff --git a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QueueCreator.java b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QueueCreator.java
index dd9faef39f..0947dd53cb 100644
--- a/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QueueCreator.java
+++ b/qpid/java/perftests/src/main/java/org/apache/qpid/disttest/jms/QueueCreator.java
@@ -20,12 +20,12 @@ package org.apache.qpid.disttest.jms;
 
 import java.util.List;
 
-import javax.jms.Connection;
+import javax.jms.Session;
 
 import org.apache.qpid.disttest.controller.config.QueueConfig;
 
 public interface QueueCreator
 {
-    public void createQueues(final Connection connection, final List<QueueConfig> configs);
-    public void deleteQueues(final Connection connection, final List<QueueConfig> configs);
+    public void createQueues(final Session session, final List<QueueConfig> configs);
+    public void deleteQueues(final Session session, final List<QueueConfig> configs);
 }