Backport da215b2e0a7b (Merge of bug24988; Repeated declare / delete of the same HA queue blows up)

Tim Watson · Tim Watson · commit 5de26986dd57 · 2012-07-27T12:17:28.000-04:00
diff --git a/test/src/com/rabbitmq/client/test/functional/HAQueues.java b/test/src/com/rabbitmq/client/test/functional/HAQueues.java
@@ -57,4 +57,12 @@ private void failRedeclare(String name, Map<String,Object> args1, Map<String,Obj
             checkShutdownSignal(AMQP.PRECONDITION_FAILED, ie);
         }
     }
+
+    public void testRapidRedeclare() throws IOException {
+        String name = "ha-redeclare";
+        for (int i = 0; i < 20; i++) {
+            channel.queueDeclare(name, true, true, false, all);
+            channel.queueDelete(name);
+        }
+    }
 }

Original file line number	Diff line number	Diff line change
`@@ -57,4 +57,12 @@ private void failRedeclare(String name, Map<String,Object> args1, Map<String,Obj`
`57`	`57`	`checkShutdownSignal(AMQP.PRECONDITION_FAILED, ie);`
`58`	`58`	`}`
`59`	`59`	`}`
	`60`	`+`
	`61`	`+ public void testRapidRedeclare() throws IOException {`
	`62`	`+ String name = "ha-redeclare";`
	`63`	`+ for (int i = 0; i < 20; i++) {`
	`64`	`+ channel.queueDeclare(name, true, true, false, all);`
	`65`	`+ channel.queueDelete(name);`
	`66`	`+ }`
	`67`	`+ }`
`60`	`68`	`}`