1 files changed, 116 insertions, 0 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
new file mode 100644
index 0000000000..784e43469e
--- /dev/null
+++ b/qpid/java/perftests/src/test/java/org/apache/qpid/systest/disttest/QpidQueueCreatorTest.java
@@ -0,0 +1,116 @@
+/*
+ * Licensed to the Apache Software Foundation (ASF) under one
+ * or more contributor license agreements.  See the NOTICE file
+ * distributed with this work for additional information
+ * regarding copyright ownership.  The ASF licenses this file
+ * to you under the Apache License, Version 2.0 (the
+ * "License"); you may not use this file except in compliance
+ * with the License.  You may obtain a copy of the License at
+ *
+ *   http://www.apache.org/licenses/LICENSE-2.0
+ *
+ * Unless required by applicable law or agreed to in writing,
+ * software distributed under the License is distributed on an
+ * "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+ * KIND, either express or implied.  See the License for the
+ * specific language governing permissions and limitations
+ * under the License.
+ */
+package org.apache.qpid.systest.disttest;
+
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+import javax.jms.Connection;
+import javax.jms.Session;
+
+import org.apache.qpid.client.AMQDestination;
+import org.apache.qpid.client.AMQSession;
+import org.apache.qpid.disttest.DistributedTestException;
+import org.apache.qpid.disttest.controller.config.QueueConfig;
+import org.apache.qpid.disttest.jms.QpidQueueCreator;
+
+public class QpidQueueCreatorTest extends DistributedTestSystemTestBase
+{
+    private static final Map<String, Object> EMPTY_ATTRIBUTES = Collections.emptyMap();
+
+    private QpidQueueCreator _creator;
+    private Session _session;
+    private List<QueueConfig> _configs;
+    private String _queueName;
+
+    @Override
+    public void setUp() throws Exception
+    {
+        super.setUp();
+        Connection connection = getConnection();
+        _session = connection.createSession(false, Session.AUTO_ACKNOWLEDGE);
+        _creator = new QpidQueueCreator();
+        _configs = new ArrayList<QueueConfig>();
+        _queueName = "direct://amq.direct//" + getTestQueueName();
+    }
+
+    public void testCreateQueueWithoutAttributes() throws Exception
+    {
+        _configs.add(new QueueConfig(_queueName, true, EMPTY_ATTRIBUTES));
+
+        assertQueueBound(_queueName, false);
+
+        _creator.createQueues(_session, _configs);
+
+        assertQueueBound(_queueName, true);
+    }
+
+    public void testCreateWithAttributes() throws Exception
+    {
+        Map<String, Object> attributes = new HashMap<String, Object>();
+        attributes.put("x-qpid-priorities", Integer.valueOf(5));
+        _configs.add(new QueueConfig(_queueName, true, attributes));
+
+        assertQueueBound(_queueName, false);
+
+        _creator.createQueues(_session, _configs);
+
+        assertQueueBound(_queueName, true);
+    }
+
+    public void testDeleteQueues() throws Exception
+    {
+        _configs.add(new QueueConfig(_queueName, true, EMPTY_ATTRIBUTES));
+
+        assertQueueBound(_queueName, false);
+
+        _creator.createQueues(_session, _configs);
+        assertQueueBound(_queueName, true);
+
+        _creator.deleteQueues(_session, _configs);
+        assertQueueBound(_queueName, false);
+    }
+
+    public void testDeleteQueueThatDoesNotExist() throws Exception
+    {
+        String queueThatDoesNotExist = _queueName;
+        List<QueueConfig> configs = new ArrayList<QueueConfig>();
+        Map<String, Object> attributes = Collections.emptyMap();
+        configs.add(new QueueConfig(queueThatDoesNotExist, true, attributes));
+
+        try
+        {
+            _creator.deleteQueues(_session, configs);
+            fail("Exception not thrown");
+        }
+        catch (DistributedTestException e)
+        {
+            // PASS
+        }
+    }
+
+    private void assertQueueBound(String queueName, boolean isBound) throws Exception
+    {
+        AMQDestination destination = (AMQDestination)_session.createQueue(queueName);
+        assertEquals("Queue is not in expected bound state", isBound, ((AMQSession<?, ?>)_session).isQueueBound(destination));
+    }
+}