Create new project: spring-cloud-azure-docker-compose/storage-queue

Author: rujche

pom.xml

@@ -82,6 +82,7 @@
     <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/service-bus/spring-cloud-stream-binders</module>
     <module>spring-cloud-azure-testcontainers/service-bus/spring-messaging</module>

spring-cloud-azure-docker-compose/storage-queue/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-storage-queue-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.0.0-beta.1</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-storage-queue</artifactId>
+      <scope>test</scope>
+    </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/storage-queue/src/test/java/StorageQueueDockerComposeTest.java

@@ -0,0 +1,39 @@
+import com.azure.spring.cloud.autoconfigure.implementation.context.AzureGlobalPropertiesAutoConfiguration;
+import com.azure.spring.cloud.autoconfigure.implementation.storage.queue.AzureStorageQueueAutoConfiguration;
+import com.azure.storage.queue.QueueClient;
+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 static org.assertj.core.api.Assertions.assertThat;
+
+@SpringBootTest(properties = {
+        "spring.docker.compose.skip.in-tests=false",
+        "spring.docker.compose.file=classpath:storage-compose.yaml",
+        "spring.docker.compose.stop.command=down",
+        "spring.cloud.azure.storage.queue.queue-name=devstoreaccount1/tc-queue"
+})
+class StorageQueueDockerComposeTest {
+
+    @Autowired
+    private QueueClient queueClient;
+
+    @Test
+    void test() {
+        String message = "Hello World!";
+        this.queueClient.create();
+        this.queueClient.sendMessage(message);
+        var messageItem = this.queueClient.receiveMessage();
+        assertThat(messageItem.getBody().toString()).isEqualTo(message);
+    }
+
+    @Configuration
+    @ImportAutoConfiguration(classes = {
+            AzureGlobalPropertiesAutoConfiguration.class,
+            AzureStorageQueueAutoConfiguration.class})
+    static class Config {
+    }
+
+}

spring-cloud-azure-docker-compose/storage-queue/src/test/resources/storage-compose.yaml

@@ -0,0 +1,7 @@
+services:
+  storage:
+    image: mcr.microsoft.com/azure-storage/azurite:latest
+    ports:
+      - '10000'
+      - '10001'
+    command: azurite -l /data --blobHost 0.0.0.0 --queueHost 0.0.0.0 --tableHost 0.0.0.0 --skipApiVersionCheck