#354 | Declare the exchange and wait until unrouted

Author: slayful

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

@@ -150,14 +150,18 @@ protected void releaseResources() throws IOException {
             channel.confirmSelect();
             assertThat(metrics.getPublishUnroutedMessages().getCount(), is(1L));
             // when
+            channel.exchangeDeclare("any-exchange", "direct");
             channel.basicPublish(
                     "any-exchange",
                     "any-routing-key",
                     MessageProperties.MINIMAL_BASIC,
                     "any-message".getBytes()
             );
-            channel.waitForConfirms(30 * 60 * 1000);
             // then
+            waitAtMost(timeout()).until(
+                    () -> metrics.getPublishUnroutedMessages().getCount(),
+                    equalTo(1L)
+            );
             assertThat(metrics.getPublishUnroutedMessages().getCount(), is(1L));
         } finally {
             safeClose(connection);