Add docker related unit tests in new projects

pom.xml

@@ -79,9 +79,19 @@
     <module>storage/spring-cloud-azure-starter-storage-file-share/storage-file-sample</module>
     <module>storage/spring-cloud-azure-starter-storage-queue/storage-queue-client</module>
     <module>storage/spring-messaging-azure-storage-queue/storage-queue-spring-messaging</module>
-    <module>testcontainers/spring-cloud-azure-testcontainers-for-cosmos-sample</module>
-    <module>testcontainers/spring-cloud-azure-testcontainers-for-storage-blob-sample</module>
-    <module>testcontainers/spring-cloud-azure-testcontainers-for-storage-queue-sample</module>
+    <module>spring-cloud-azure-docker-compose/event-hubs/client</module>
+    <module>spring-cloud-azure-docker-compose/event-hubs/spring-cloud-stream-binders</module>
+    <module>spring-cloud-azure-docker-compose/service-bus/spring-cloud-stream-binders</module>
+    <module>spring-cloud-azure-docker-compose/service-bus/spring-messaging</module>
+    <module>spring-cloud-azure-docker-compose/storage-blob</module>
+    <module>spring-cloud-azure-docker-compose/storage-queue</module>
+    <module>spring-cloud-azure-testcontainers/cosmos</module>
+    <module>spring-cloud-azure-testcontainers/event-hubs/client</module>
+    <module>spring-cloud-azure-testcontainers/event-hubs/spring-cloud-stream-binders</module>
+    <module>spring-cloud-azure-testcontainers/service-bus/spring-cloud-stream-binders</module>
+    <module>spring-cloud-azure-testcontainers/service-bus/spring-messaging</module>
+    <module>spring-cloud-azure-testcontainers/storage-blob</module>
+    <module>spring-cloud-azure-testcontainers/storage-queue</module>
   </modules>
 
 </project>

spring-cloud-azure-docker-compose/event-hubs/client/pom.xml

@@ -0,0 +1,55 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xmlns="http://maven.apache.org/POM/4.0.0"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.springframework.boot</groupId>
+    <artifactId>spring-boot-starter-parent</artifactId>
+    <version>4.0.3</version>
+    <relativePath/> <!-- lookup parent from repository -->
+  </parent>
+
+  <groupId>com.azure.spring</groupId>
+  <artifactId>spring-cloud-azure-docker-compose-for-event-hubs-client-sample</artifactId>
+  <version>1.0.0</version>
+  <packaging>jar</packaging>
+
+  <properties>
+    <maven.compiler.source>17</maven.compiler.source>
+    <maven.compiler.target>17</maven.compiler.target>
+    <version.spring.cloud.azure>7.1.0</version.spring.cloud.azure>
+  </properties>
+
+  <dependencyManagement>
+    <dependencies>
+      <dependency>
+        <groupId>com.azure.spring</groupId>
+        <artifactId>spring-cloud-azure-dependencies</artifactId>
+        <version>${version.spring.cloud.azure}</version>
+        <type>pom</type>
+        <scope>import</scope>
+      </dependency>
+    </dependencies>
+  </dependencyManagement>
+
+  <dependencies>
+    <dependency>
+      <groupId>com.azure.spring</groupId>
+      <artifactId>spring-cloud-azure-starter-eventhubs</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-test</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>com.azure.spring</groupId>
+      <artifactId>spring-cloud-azure-docker-compose</artifactId>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+
+</project>

spring-cloud-azure-docker-compose/event-hubs/client/src/test/java/EventHubsDockerComposeTest.java

@@ -0,0 +1,57 @@
+import com.azure.messaging.eventhubs.EventData;
+import com.azure.messaging.eventhubs.EventHubProducerClient;
+import com.azure.spring.cloud.autoconfigure.implementation.context.AzureGlobalPropertiesAutoConfiguration;
+import com.azure.spring.cloud.autoconfigure.implementation.eventhubs.AzureEventHubsAutoConfiguration;
+import com.azure.spring.cloud.autoconfigure.implementation.eventhubs.properties.AzureEventHubsConnectionDetails;
+import org.junit.jupiter.api.Test;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.autoconfigure.ImportAutoConfiguration;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.annotation.Configuration;
+
+import java.time.Duration;
+import java.util.Collections;
+
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.waitAtMost;
+
+@SpringBootTest(properties = {
+        "spring.docker.compose.skip.in-tests=false",
+        "spring.docker.compose.file=classpath:eventhubs-compose.yaml",
+        "spring.docker.compose.stop.command=down",
+        "spring.docker.compose.readiness.timeout=PT5M",
+        "spring.cloud.azure.eventhubs.event-hub-name=eh1",
+        "spring.cloud.azure.eventhubs.producer.event-hub-name=eh1"
+})
+class EventHubsDockerComposeTest {
+
+    @Autowired
+    private AzureEventHubsConnectionDetails connectionDetails;
+
+    @Autowired
+    private EventHubProducerClient producerClient;
+
+    @Test
+    void connectionDetailsShouldBeProvidedByFactory() {
+        assertThat(connectionDetails).isNotNull();
+        assertThat(connectionDetails.getConnectionString())
+                .isNotBlank()
+                .startsWith("Endpoint=sb://");
+    }
+
+    @Test
+    void producerClientCanSendMessage() {
+        // Wait for Event Hubs emulator to be fully ready and event hub entity to be available
+        waitAtMost(Duration.ofSeconds(120)).pollInterval(Duration.ofSeconds(2)).untilAsserted(() -> {
+            EventData event = new EventData("Hello World!");
+            this.producerClient.send(Collections.singletonList(event));
+        });
+    }
+
+    @Configuration(proxyBeanMethods = false)
+    @ImportAutoConfiguration(classes = {
+            AzureGlobalPropertiesAutoConfiguration.class,
+            AzureEventHubsAutoConfiguration.class})
+    static class Config {
+    }
+}

spring-cloud-azure-docker-compose/event-hubs/client/src/test/resources/Config.json

@@ -0,0 +1,20 @@
+{
+  "UserConfig": {
+    "NamespaceConfig": [
+      {
+        "Type": "EventHub",
+        "Name": "emulatorns1",
+        "Entities": [
+          {
+            "Name": "eh1",
+            "PartitionCount": "2",
+            "ConsumerGroups": []
+          }
+        ]
+      }
+    ],
+    "LoggingConfig": {
+      "Type": "File"
+    }
+  }
+}

spring-cloud-azure-docker-compose/event-hubs/client/src/test/resources/eventhubs-compose.yaml

@@ -0,0 +1,34 @@
+services:
+  eventhubs:
+    image: mcr.microsoft.com/azure-messaging/eventhubs-emulator:latest
+    pull_policy: always
+    volumes:
+      # Mount the emulator configuration to the path expected by the emulator image
+      - "./Config.json:/Eventhubs_Emulator/ConfigFiles/Config.json"
+    ports:
+      - "5672"
+    environment:
+      # Event Hubs emulator requires external blob/metadata storage provided by azurite
+      BLOB_SERVER: azurite
+      METADATA_SERVER: azurite
+      ACCEPT_EULA: Y
+    depends_on:
+      - azurite
+    networks:
+      eh-emulator:
+        aliases:
+          - "eh-emulator"
+
+  azurite:
+    image: "mcr.microsoft.com/azure-storage/azurite:latest"
+    ports:
+      - "10000"
+      - "10001"
+      - "10002"
+    networks:
+      eh-emulator:
+        aliases:
+          - "azurite"
+
+networks:
+  eh-emulator:

spring-cloud-azure-docker-compose/event-hubs/spring-cloud-stream-binders/pom.xml

@@ -0,0 +1,59 @@
+<?xml version="1.0" encoding="UTF-8"?>
+
+<project xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xmlns="http://maven.apache.org/POM/4.0.0"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <parent>
+    <groupId>org.springframework.boot</groupId>
+    <artifactId>spring-boot-starter-parent</artifactId>
+    <version>4.0.3</version>
+    <relativePath/> <!-- lookup parent from repository -->
+  </parent>
+
+  <groupId>com.azure.spring</groupId>
+  <artifactId>spring-cloud-azure-docker-compose-for-event-hubs-spring-cloud-stream-sample</artifactId>
+  <version>1.0.0</version>
+  <packaging>jar</packaging>
+
+  <properties>
+    <maven.compiler.source>17</maven.compiler.source>
+    <maven.compiler.target>17</maven.compiler.target>
+    <version.spring.cloud.azure>7.1.0</version.spring.cloud.azure>
+  </properties>
+
+  <dependencyManagement>
+    <dependencies>
+      <dependency>
+        <groupId>com.azure.spring</groupId>
+        <artifactId>spring-cloud-azure-dependencies</artifactId>
+        <version>${version.spring.cloud.azure}</version>
+        <type>pom</type>
+        <scope>import</scope>
+      </dependency>
+    </dependencies>
+  </dependencyManagement>
+
+  <dependencies>
+    <dependency>
+      <groupId>com.azure</groupId>
+      <artifactId>azure-messaging-eventhubs</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>com.azure.spring</groupId>
+      <artifactId>spring-cloud-azure-stream-binder-eventhubs</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-test</artifactId>
+      <scope>test</scope>
+    </dependency>
+    <dependency>
+      <groupId>com.azure.spring</groupId>
+      <artifactId>spring-cloud-azure-docker-compose</artifactId>
+      <scope>test</scope>
+    </dependency>
+  </dependencies>
+
+</project>

spring-cloud-azure-docker-compose/event-hubs/spring-cloud-stream-binders/src/test/java/EventHubsDockerComposeTest.java

@@ -0,0 +1,112 @@
+import com.azure.messaging.eventhubs.checkpointstore.blob.BlobCheckpointStore;
+import com.azure.spring.cloud.autoconfigure.implementation.context.AzureGlobalPropertiesAutoConfiguration;
+import com.azure.spring.cloud.autoconfigure.implementation.eventhubs.AzureEventHubsAutoConfiguration;
+import com.azure.spring.cloud.autoconfigure.implementation.eventhubs.AzureEventHubsMessagingAutoConfiguration;
+import com.azure.spring.cloud.autoconfigure.implementation.storage.blob.properties.AzureStorageBlobConnectionDetails;
+import com.azure.spring.messaging.checkpoint.Checkpointer;
+import com.azure.storage.blob.BlobContainerAsyncClient;
+import com.azure.storage.blob.BlobServiceAsyncClient;
+import com.azure.storage.blob.BlobServiceClientBuilder;
+import org.junit.jupiter.api.Test;
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
+import org.springframework.boot.autoconfigure.ImportAutoConfiguration;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.messaging.Message;
+import org.springframework.messaging.support.MessageBuilder;
+
+import java.time.Duration;
+import java.util.Set;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.atomic.AtomicInteger;
+import java.util.function.Consumer;
+import java.util.function.Supplier;
+
+import static com.azure.spring.messaging.AzureHeaders.CHECKPOINTER;
+import static org.assertj.core.api.Assertions.assertThat;
+import static org.awaitility.Awaitility.waitAtMost;
+
+@SpringBootTest(properties = {
+        "spring.docker.compose.skip.in-tests=false",
+        "spring.docker.compose.file=classpath:eventhubs-compose.yaml",
+        "spring.docker.compose.stop.command=down",
+        "spring.docker.compose.readiness.timeout=PT5M",
+        "spring.cloud.function.definition=consume;supply",
+        "spring.cloud.stream.bindings.consume-in-0.destination=eh1",
+        "spring.cloud.stream.bindings.consume-in-0.group=$Default",
+        "spring.cloud.stream.bindings.supply-out-0.destination=eh1",
+        "spring.cloud.stream.eventhubs.bindings.consume-in-0.consumer.checkpoint.mode=MANUAL",
+        "spring.cloud.stream.poller.fixed-delay=1000",
+        "spring.cloud.stream.poller.initial-delay=0"
+})
+class EventHubsDockerComposeTest {
+
+    private static final Logger LOGGER = LoggerFactory.getLogger(EventHubsDockerComposeTest.class);
+    private static final Set<String> RECEIVED_MESSAGES = ConcurrentHashMap.newKeySet();
+    private static final AtomicInteger MESSAGE_SEQUENCE = new AtomicInteger(0);
+
+    @Test
+    void supplierAndConsumerShouldWorkThroughEventHub() {
+        waitAtMost(Duration.ofSeconds(120))
+                .pollDelay(Duration.ofSeconds(2))
+                .pollInterval(Duration.ofSeconds(2))
+                .untilAsserted(() -> {
+                    assertThat(RECEIVED_MESSAGES).isNotEmpty();
+                    LOGGER.info("✓ Test passed - Consumer received {} message(s)", RECEIVED_MESSAGES.size());
+                });
+    }
+
+    @Configuration(proxyBeanMethods = false)
+    @EnableAutoConfiguration
+    @ImportAutoConfiguration(classes = {
+            AzureGlobalPropertiesAutoConfiguration.class,
+            AzureEventHubsAutoConfiguration.class,
+            AzureEventHubsMessagingAutoConfiguration.class})
+    static class Config {
+
+        private static final String CHECKPOINT_CONTAINER_NAME = "eventhubs-checkpoint";
+
+        @Bean
+        public BlobCheckpointStore blobCheckpointStore(AzureStorageBlobConnectionDetails connectionDetails) {
+            BlobServiceAsyncClient blobServiceAsyncClient = new BlobServiceClientBuilder()
+                    .connectionString(connectionDetails.getConnectionString())
+                    .buildAsyncClient();
+            BlobContainerAsyncClient containerAsyncClient = blobServiceAsyncClient
+                    .getBlobContainerAsyncClient(CHECKPOINT_CONTAINER_NAME);
+            if (Boolean.FALSE.equals(containerAsyncClient.exists().block(Duration.ofSeconds(3)))) {
+                containerAsyncClient.create().block(Duration.ofSeconds(3));
+            }
+            return new BlobCheckpointStore(containerAsyncClient);
+        }
+
+        @Bean
+        public Supplier<Message<String>> supply() {
+            return () -> {
+                int sequence = MESSAGE_SEQUENCE.getAndIncrement();
+                String payload = "Hello world, " + sequence;
+                LOGGER.info("[Supplier] Invoked - message sequence: {}", sequence);
+                return MessageBuilder.withPayload(payload).build();
+            };
+        }
+
+        @Bean
+        public Consumer<Message<String>> consume() {
+            return message -> {
+                String payload = message.getPayload();
+                RECEIVED_MESSAGES.add(payload);
+                LOGGER.info("[Consumer] Received message: {}", payload);
+
+                Checkpointer checkpointer = (Checkpointer) message.getHeaders().get(CHECKPOINTER);
+                if (checkpointer != null) {
+                    checkpointer.success()
+                            .doOnSuccess(s -> LOGGER.info("[Consumer] Message checkpointed"))
+                            .doOnError(e -> LOGGER.error("[Consumer] Checkpoint failed", e))
+                            .block();
+                }
+            };
+        }
+    }
+}

spring-cloud-azure-docker-compose/event-hubs/spring-cloud-stream-binders/src/test/resources/Config.json

@@ -0,0 +1,20 @@
+{
+  "UserConfig": {
+    "NamespaceConfig": [
+      {
+        "Type": "EventHub",
+        "Name": "emulatorns1",
+        "Entities": [
+          {
+            "Name": "eh1",
+            "PartitionCount": "2",
+            "ConsumerGroups": []
+          }
+        ]
+      }
+    ],
+    "LoggingConfig": {
+      "Type": "File"
+    }
+  }
+}