Merge bug25164

Author: Simon MacMullen

test/src/com/rabbitmq/client/test/server/AbsentQueue.java

@@ -0,0 +1,99 @@
+//  The contents of this file are subject to the Mozilla Public License
+//  Version 1.1 (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.mozilla.org/MPL/
+//
+//  Software distributed under the License is distributed on an "AS IS"
+//  basis, WITHOUT WARRANTY OF ANY KIND, either express or implied. See
+//  the License for the specific language governing rights and
+//  limitations under the License.
+//
+//  The Original Code is RabbitMQ.
+//
+//  The Initial Developer of the Original Code is VMware, Inc.
+//  Copyright (c) 2007-2012 VMware, Inc.  All rights reserved.
+//
+
+
+package com.rabbitmq.client.test.server;
+
+import com.rabbitmq.client.AMQP;
+import com.rabbitmq.client.test.functional.ClusteredTestBase;
+import com.rabbitmq.tools.Host;
+
+import java.io.IOException;
+
+/**
+ * This tests whether 'absent' queues - durable queues whose home node
+ * is down - are handled properly.
+ */
+public class AbsentQueue extends ClusteredTestBase {
+
+    private static final String Q = "absent-queue";
+
+    @Override protected void setUp() throws IOException {
+        super.setUp();
+        if (clusteredConnection != null)
+            Host.executeCommand("cd ../rabbitmq-test; make stop-secondary-app");
+    }
+
+    @Override protected void tearDown() throws IOException {
+        if (clusteredConnection != null)
+            Host.executeCommand("cd ../rabbitmq-test; make start-secondary-app");
+        super.tearDown();
+    }
+
+    @Override protected void createResources() throws IOException {
+        alternateChannel.queueDeclare(Q, true, false, false, null);
+    }
+
+    @Override protected void releaseResources() throws IOException {
+        alternateChannel.queueDelete(Q);
+    }
+
+    public void testNotFound() throws IOException {
+        assertNotFound(new Task() {
+                public void run() throws IOException {
+                    channel.queueDeclare(Q, true, false, false, null);
+                }
+            });
+        assertNotFound(new Task() {
+                public void run() throws IOException {
+                    channel.queueDeclarePassive(Q);
+                }
+            });
+        assertNotFound(new Task() {
+                public void run() throws IOException {
+                    channel.queuePurge(Q);
+                }
+            });
+        assertNotFound(new Task() {
+                public void run() throws IOException {
+                    channel.basicGet(Q, true);
+                }
+            });
+        assertNotFound(new Task() {
+                public void run() throws IOException {
+                    channel.queueBind(Q, "amq.fanout", "", null);
+                }
+            });
+    }
+
+    protected void assertNotFound(Task t) throws IOException {
+        if (clusteredChannel == null) return;
+        try {
+            t.run();
+            if (!HATests.HA_TESTS_RUNNING) fail("expected not_found");
+        } catch (IOException ioe) {
+            assertFalse(HATests.HA_TESTS_RUNNING);
+            checkShutdownSignal(AMQP.NOT_FOUND, ioe);
+            channel = connection.createChannel();
+        }
+
+    }
+
+    private interface Task {
+        public void run() throws IOException;
+    }
+
+}

test/src/com/rabbitmq/client/test/server/ServerTests.java

@@ -32,6 +32,7 @@ public static void add(TestSuite suite) {
         suite.addTestSuite(DurableBindingLifecycle.class);
         suite.addTestSuite(EffectVisibilityCrossNodeTest.class);
         suite.addTestSuite(ExclusiveQueueDurability.class);
+        suite.addTestSuite(AbsentQueue.class);
         suite.addTestSuite(AlternateExchangeEquivalence.class);
         suite.addTestSuite(MemoryAlarms.class);
         suite.addTestSuite(MessageRecovery.class);