Disable auto recovery in DeadLetterExchange test

Fixes #210

Author: acogoluegnes

src/test/java/com/rabbitmq/client/test/BrokerTestCase.java

@@ -60,9 +60,14 @@ protected void finished(Description description) {
 
     protected ConnectionFactory newConnectionFactory() {
         ConnectionFactory connectionFactory = TestUtils.connectionFactory();
+        connectionFactory.setAutomaticRecoveryEnabled(isAutomaticRecoveryEnabled());
         return connectionFactory;
     }
 
+    protected boolean isAutomaticRecoveryEnabled() {
+        return true;
+    }
+
     protected Connection connection;
     protected Channel channel;
 

src/test/java/com/rabbitmq/client/test/functional/DeadLetterExchange.java

@@ -55,6 +55,11 @@ public class DeadLetterExchange extends BrokerTestCase {
     public static final int MSG_COUNT = 10;
     public static final int TTL = 1000;
 
+    @Override
+    protected boolean isAutomaticRecoveryEnabled() {
+        return false;
+    }
+
     @Override
     protected void createResources() throws IOException {
         channel.exchangeDelete(DLX);
@@ -164,10 +169,6 @@ protected void releaseResources() throws IOException {
 
             args.put(DLX_RK_ARG, "foo");
 
-            // sleep a little, otherwise the resource is still locked
-            // before the next call and we get a 405 - resource locked
-            Thread.sleep(100L);
-
             channel.queueDeclare("bar", false, true, false, args);
             fail("x-dead-letter-exchange must be specified if " +
                     "x-dead-letter-routing-key is set");

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

@@ -33,6 +33,14 @@
  */
 public class ExclusiveQueueDurability extends BrokerTestCase {
 
+    @Override
+    protected boolean isAutomaticRecoveryEnabled() {
+        // With automatic recovery enabled, queue can be re-created when launching the test suite
+        // (because FunctionalTests are launched independently and as part of the HATests)
+        // This then makes this test fail.
+        return false;
+    }
+
     void verifyQueueMissing(Channel channel, String queueName)
             throws IOException {
         try {