RabbitMQ: Support declaring an exchange within a vhost (#2362)

Author: dangets

modules/rabbitmq/src/main/java/org/testcontainers/containers/RabbitMQContainer.java

@@ -345,6 +345,17 @@ public RabbitMQContainer withExchange(String name, String type) {
 
     public RabbitMQContainer withExchange(String name, String type, boolean autoDelete, boolean internal, boolean durable, Map<String, Object> arguments) {
         values.add(asList("rabbitmqadmin", "declare", "exchange",
+            "name=" + name,
+            "type=" + type,
+            "auto_delete=" + autoDelete,
+            "internal=" + internal,
+            "durable=" + durable,
+            "arguments=" + toJson(arguments)));
+        return self();
+    }
+
+    public RabbitMQContainer withExchange(String vhost, String name, String type, boolean autoDelete, boolean internal, boolean durable, Map<String, Object> arguments) {
+        values.add(asList("rabbitmqadmin", "--vhost=" + vhost, "declare", "exchange",
                 "name=" + name,
                 "type=" + type,
                 "auto_delete=" + autoDelete,

modules/rabbitmq/src/test/java/org/testcontainers/containers/RabbitMQContainerTest.java

@@ -19,6 +19,7 @@
 import java.security.NoSuchAlgorithmException;
 import java.security.UnrecoverableKeyException;
 import java.security.cert.CertificateException;
+import java.util.Collections;
 import javax.net.ssl.KeyManagerFactory;
 import javax.net.ssl.SSLContext;
 import javax.net.ssl.TrustManagerFactory;
@@ -91,6 +92,20 @@ public void shouldCreateRabbitMQContainerWithExchange() throws IOException, Inte
         }
     }
 
+    @Test
+    public void shouldCreateRabbitMQContainerWithExchangeInVhost() throws IOException, InterruptedException
+    {
+        try (RabbitMQContainer container = new RabbitMQContainer()) {
+            container.withVhost("test-vhost");
+            container.withExchange("test-vhost", "test-exchange", "direct", false, false, false, Collections.emptyMap());
+
+            container.start();
+
+            assertThat(container.execInContainer("rabbitmqctl", "list_exchanges", "-p", "test-vhost").getStdout())
+                .containsPattern("test-exchange\\s+direct");
+        }
+    }
+
     @Test
     public void shouldCreateRabbitMQContainerWithQueues() throws IOException, InterruptedException
     {