Remove use of ha-mode policy

Classic mirrored queues are deprecated in RabbitMQ 3.13 and gone in
RabbitMQ 4.0, so we do not test them anymore.

Author: acogoluegnes

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

@@ -35,7 +35,6 @@
 public class BrokerTestCase {
 
     private String brokerVersion;
-    private boolean ha = false;
 
     protected volatile TestInfo testInfo;
 
@@ -343,10 +342,6 @@ private static String name(String prefix, Class<?> testClass, String testMethodN
             prefix, testClass.getSimpleName(), testMethodName, uuid.substring(uuid.length() / 2));
     }
 
-    protected boolean ha() {
-        return this.ha;
-    }
-
     protected boolean beforeMessageContainers() {
        return versionCompare(this.brokerVersion, "3.13.0") < 0;
     }

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

@@ -180,12 +180,6 @@ public class Policies extends BrokerTestCase {
     private final Set<String> policies = new HashSet<String>();
 
     private void setPolicy(String name, String pattern, String definition) throws IOException {
-        // We need to override the HA policy that we use in HATests, so
-        // priority 1. But we still want a valid test of HA, so add the
-        // ha-mode definition.
-        if (ha()) {
-            definition += ",\"ha-mode\":\"all\"";
-        }
         Host.rabbitmqctl("set_policy --priority 1 " + name + " " + pattern +
                          " {" + escapeDefinition(definition) + "}");
         policies.add(name);

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

@@ -50,9 +50,6 @@ protected void releaseResources() throws IOException {
     }
 
     @Test public void deadLetterQueueTTLExpiredWhileDown() throws Exception {
-        // This test is nonsensical (and often breaks) in HA mode.
-        if (ha()) return;
-
         for(int x = 0; x < DeadLetterExchange.MSG_COUNT; x++) {
             channel.basicPublish("amq.direct", "test", MessageProperties.MINIMAL_PERSISTENT_BASIC, "test message".getBytes());
         }

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

@@ -46,26 +46,7 @@ public class MessageRecovery extends ConfirmBase
 
         restart();
 
-        // When testing in HA mode the message will be collected from
-        // a promoted slave and will have its redelivered flag
-        // set. But that only happens if there actually *is* a
-        // slave. We test that by passively declaring, and
-        // subsequently deleting, the secondary, non-durable queue,
-        // which only succeeds if the queue survived the restart,
-        // which in turn implies that it must have been a HA queue
-        // with slave(s).
-        // NB: this wont work when running against a single node broker
-        // and running the test individually outside of the HA suite
-        boolean expectDelivered = ha();
-        try {
-            channel.queueDeclarePassive(Q2);
-            channel.queueDelete(Q2);
-            expectDelivered = true;
-        } catch (IOException e) {
-            checkShutdownSignal(AMQP.NOT_FOUND, e);
-            openChannel();
-        }
-        assertDelivered(Q, 1, expectDelivered);
+        assertDelivered(Q, 1, false);
         channel.queueDelete(Q);
         channel.queueDelete(Q2);
     }