Make sure queue exists before binding it

This fails only on CI, which can be very slow.

Author: acogoluegnes

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

@@ -30,7 +30,9 @@
 import java.util.concurrent.TimeoutException;
 
 import static com.rabbitmq.client.test.TestUtils.currentVersion;
+import static com.rabbitmq.client.test.TestUtils.queueExists;
 import static com.rabbitmq.client.test.TestUtils.versionCompare;
+import static com.rabbitmq.client.test.TestUtils.waitAtMost;
 import static org.junit.jupiter.api.Assertions.*;
 
 public class BrokerTestCase {
@@ -247,13 +249,10 @@ public void basicPublishVolatile(byte[] msg, String x, String routingKey,
 
     protected void declareAndBindDurableQueue(String q, String x, String r) throws IOException {
         declareDurableQueue(q);
+        waitAtMost(() -> queueExists(q, this.connection));
         channel.queueBind(q, x, r);
     }
 
-    protected void declareDurableDirectExchange(String x) throws IOException {
-        channel.exchangeDeclare(x, "direct", true);
-    }
-
     protected void declareDurableQueue(String q) throws IOException {
         channel.queueDeclare(q, true, false, false, null);
     }