Tests pass, needed azure-messaging-servicebus:7.17.8

Author: computerlove

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

@@ -24,10 +24,11 @@ public class ServicebusEmulatorContainerTest {
     );
 
     @Test
-    public void testWithDefaultConfig() {
+    public void testWithASBClient() {
+        Integer mappedPort = servicebusEmulatorContainer.getMappedPort(5672);
         List<String> sentMessages = Arrays.asList("Hello World");
         try(ServiceBusSenderClient sender = new ServiceBusClientBuilder()
-            .connectionString(servicebusEmulatorContainer.getConnectionString())
+            .connectionString("Endpoint=sb://localhost:" + mappedPort + ";SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;")
             .sender()
             .queueName("queue.1")
             .buildClient()) {
@@ -36,7 +37,7 @@ public void testWithDefaultConfig() {
             }
         }
         try(ServiceBusReceiverClient reciever = new ServiceBusClientBuilder()
-            .connectionString(servicebusEmulatorContainer.getConnectionString())
+            .connectionString("Endpoint=sb://localhost:" + mappedPort + ";SharedAccessKeyName=RootManageSharedAccessKey;SharedAccessKey=SAS_KEY_VALUE;UseDevelopmentEmulator=true;")
             .receiver()
             .queueName("queue.1")
             .receiveMode(ServiceBusReceiveMode.RECEIVE_AND_DELETE)
@@ -46,29 +47,4 @@ public void testWithDefaultConfig() {
             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);
-        }
-    }
 }