Tests pass, needed azure-messaging-servicebus:7.17.8

Author: computerlove

modules/azure/src/main/java/org/testcontainers/containers/ServicebusEmulatorContainer.java

@@ -2,6 +2,7 @@
 
 import org.testcontainers.containers.wait.strategy.Wait;
 import org.testcontainers.utility.DockerImageName;
+import org.testcontainers.utility.MountableFile;
 
 public class ServicebusEmulatorContainer<SELF extends ServicebusEmulatorContainer<SELF>> extends GenericContainer<SELF> {
     private static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse(
@@ -33,7 +34,13 @@ public ServicebusEmulatorContainer(final DockerImageName dockerImageName) {
         addEnv("MSSQL_SA_PASSWORD", mssqlServerContainer.getPassword());
         addEnv("SQL_SERVER", mssqlNetworkAlias);
         acceptLicense();
-        addEnv("CONFIG_PATH", "/home/marvin.lillehaug/src/testcontainers-java/modules/azure/src/test/resources/servicebus-config.json");
+    }
+
+    public SELF withConfigFile(MountableFile configFile) {
+        return withCopyFileToContainer(
+            configFile,
+            "/ServiceBus_Emulator/ConfigFiles/Config.json"
+        );
     }
 
     /**
@@ -44,4 +51,9 @@ public SELF acceptLicense() {
         addEnv("ACCEPT_EULA", "Y");
         return self();
     }
+
+    public String getConnectionString() {
+        Integer mappedPort = getMappedPort(5672);
+        return "Endpoint=sb://localhost:" + mappedPort + ";SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;";
+    }
 }

modules/azure/src/test/java/org/testcontainers/containers/ServicebusEmulatorContainerTest.java

@@ -24,11 +24,10 @@ public class ServicebusEmulatorContainerTest {
     );
 
     @Test
-    public void testWithASBClient() {
-        Integer mappedPort = servicebusEmulatorContainer.getMappedPort(5672);
+    public void testWithDefaultConfig() {
         List<String> sentMessages = Arrays.asList("Hello World");
         try(ServiceBusSenderClient sender = new ServiceBusClientBuilder()
-            .connectionString("Endpoint=sb://localhost:" + mappedPort + ";SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;")
+            .connectionString(servicebusEmulatorContainer.getConnectionString())
             .sender()
             .queueName("queue.1")
             .buildClient()) {
@@ -37,7 +36,7 @@ public void testWithASBClient() {
             }
         }
         try(ServiceBusReceiverClient reciever = new ServiceBusClientBuilder()
-            .connectionString("Endpoint=sb://localhost:" + mappedPort + ";SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;")
+            .connectionString(servicebusEmulatorContainer.getConnectionString())
             .receiver()
             .queueName("queue.1")
             .receiveMode(ServiceBusReceiveMode.RECEIVE_AND_DELETE)
@@ -47,4 +46,29 @@ public void testWithASBClient() {
             assertThat(recievedMessages).isEqualTo(sentMessages);
         }
     }
+
+
+    @Test
+    public void testWithCustomConfig() {
+        List<String> sentMessages = Arrays.asList("Hello World");
+        try(ServiceBusSenderClient sender = new ServiceBusClientBuilder()
+            .connectionString(servicebusEmulatorContainer.getConnectionString())
+            .sender()
+            .queueName("queue.666")
+            .buildClient()) {
+            for (String m : sentMessages) {
+                sender.sendMessage(new ServiceBusMessage(m));
+            }
+        }
+        try(ServiceBusReceiverClient reciever = new ServiceBusClientBuilder()
+            .connectionString(servicebusEmulatorContainer.getConnectionString())
+            .receiver()
+            .queueName("queue.666")
+            .receiveMode(ServiceBusReceiveMode.RECEIVE_AND_DELETE)
+            .buildClient()) {
+            IterableStream<ServiceBusReceivedMessage> messagesStream = reciever.receiveMessages(sentMessages.size());
+            List<String> recievedMessages = messagesStream.stream().map(m -> m.getBody().toString()).collect(Collectors.toList());
+            assertThat(recievedMessages).isEqualTo(sentMessages);
+        }
+    }
 }