ServicebusEmulatorContainer, SqlEdgeContainer

Author: computerlove

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

@@ -0,0 +1,32 @@
+package org.testcontainers.containers;
+
+import org.testcontainers.containers.wait.strategy.Wait;
+import org.testcontainers.utility.DockerImageName;
+
+public class ServicebusEmulatorContainer extends GenericContainer<ServicebusEmulatorContainer> {
+    private static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse(
+        "mcr.microsoft.com/azure-messaging/servicebus-emulator"
+    );
+
+    private static final int PORT = 1433;
+
+    /**
+     * @param dockerImageName specified docker image name to run
+     */
+    public ServicebusEmulatorContainer(final DockerImageName dockerImageName) {
+        super(dockerImageName);
+        dockerImageName.assertCompatibleWith(DEFAULT_IMAGE_NAME);
+        withExposedPorts(PORT);
+        waitingFor(Wait.forLogMessage(".*Emulator Service is Successfully Up!\\r\\n$", 1));
+        Network network = Network.newNetwork();
+        withNetwork(network);
+        withNetworkAliases("sb-emulator");
+        dependsOn(
+             new SqlEdgeContainer(DockerImageName.parse("mcr.microsoft.com/azure-sql-edge:latest"))
+                 .withNetwork(network)
+                 .withNetworkAliases("sqledge")
+        );
+        addEnv("ACCEPT_EULA", "Y");
+        addEnv("CONFIG_PATH", "/home/marv/Downloads/asb/config.json");
+    }
+}

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

@@ -0,0 +1,32 @@
+package org.testcontainers.containers;
+
+import org.testcontainers.containers.wait.strategy.Wait;
+import org.testcontainers.utility.DockerImageName;
+
+/**
+ * Testcontainers implementation for Sql Edge.
+ * <p>
+ * Supported image: {@code mcr.microsoft.com/azure-sql-edge}
+ * <p>
+ * Exposed ports: 1433
+ */
+public class SqlEdgeContainer extends GenericContainer<SqlEdgeContainer> {
+    private static final DockerImageName DEFAULT_IMAGE_NAME = DockerImageName.parse(
+        "mcr.microsoft.com/azure-sql-edge"
+    );
+
+    private static final int PORT = 1433;
+
+    /**
+     * @param dockerImageName specified docker image name to run
+     */
+    public SqlEdgeContainer(final DockerImageName dockerImageName) {
+        super(dockerImageName);
+        dockerImageName.assertCompatibleWith(DEFAULT_IMAGE_NAME);
+        withExposedPorts(PORT);
+        waitingFor(Wait.forLogMessage(".*Service Broker manager has started.\\r\\n$", 1));
+        addEnv("ACCEPT_EULA", "Y");
+        addEnv("MSSQL_SA_PASSWORD", "J3R4uUWLTjDqTXoQnvXu");
+    }
+
+}

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

@@ -0,0 +1,17 @@
+package org.testcontainers.containers;
+
+import org.junit.Rule;
+import org.junit.Test;
+import org.testcontainers.utility.DockerImageName;
+
+public class ServicebusEmulatorContainerTest {
+    @Rule
+    public ServicebusEmulatorContainer servicebusEmulatorContainer = new ServicebusEmulatorContainer(
+        DockerImageName.parse("mcr.microsoft.com/azure-messaging/servicebus-emulator")
+    );
+
+    @Test
+    public void testWIthASBClient() {
+        String containerId = servicebusEmulatorContainer.getContainerId();
+    }
+}

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

@@ -0,0 +1,18 @@
+package org.testcontainers.containers;
+
+
+import org.junit.Rule;
+import org.junit.Test;
+import org.testcontainers.utility.DockerImageName;
+
+public class SqlEdgeContainerTest {
+    @Rule
+    public SqlEdgeContainer sqlEdgeContainer = new SqlEdgeContainer(
+        DockerImageName.parse("mcr.microsoft.com/azure-sql-edge:latest")
+    );
+
+    @Test
+    public void testWithJdbc() {
+        String host = sqlEdgeContainer.getHost();
+    }
+}