tags for created SQS

agorapulse · Aug 8, 2023 · 8379ce6 · 8379ce6
1 parent b0b74bb
commit 8379ce6
Show file tree

Hide file tree

Showing 6 changed files with 43 additions and 0 deletions.
diff --git a/...s/src/main/java/com/agorapulse/micronaut/amazon/awssdk/sqs/DefaultSimpleQueueService.java b/...s/src/main/java/com/agorapulse/micronaut/amazon/awssdk/sqs/DefaultSimpleQueueService.java
@@ -111,6 +111,10 @@ public String createQueue(QueueConfiguration configuration) {
             createQueueRequest.attributes(attributes);
         }
 
+        if (configuration.getTags() != null && !configuration.getTags().isEmpty()) {
+            createQueueRequest.tags(configuration.getTags());
+        }
+
         String queueUrl = client.createQueue(createQueueRequest.build()).queueUrl();
 
         LOGGER.debug("Queue created (queueUrl={})", queueUrl);

diff --git a/...ssdk-sqs/src/main/java/com/agorapulse/micronaut/amazon/awssdk/sqs/QueueConfiguration.java b/...ssdk-sqs/src/main/java/com/agorapulse/micronaut/amazon/awssdk/sqs/QueueConfiguration.java
@@ -19,6 +19,8 @@
 
 import javax.validation.constraints.Max;
 import javax.validation.constraints.Min;
+import java.util.LinkedHashMap;
+import java.util.Map;
 
 public class QueueConfiguration implements Cloneable {
     public QueueConfiguration withQueue(String queue) {
@@ -113,6 +115,14 @@ public void setVisibilityTimeout(Integer visibilityTimeout) {
         this.visibilityTimeout = visibilityTimeout;
     }
 
+    public Map<String, String> getTags() {
+        return tags;
+    }
+
+    public void setTags(Map<String, String> tags) {
+        this.tags = tags;
+    }
+
     private String queue = "";
     private boolean fifo;
 
@@ -131,4 +141,6 @@ public void setVisibilityTimeout(Integer visibilityTimeout) {
     @Min(0L)
     @Max(43200L)
     private Integer visibilityTimeout = 30;
+
+    private Map<String, String> tags = new LinkedHashMap<>();
 }
diff --git a/subprojects/micronaut-amazon-awssdk-sqs/src/test/resources/application-test.yml b/subprojects/micronaut-amazon-awssdk-sqs/src/test/resources/application-test.yml
@@ -1,3 +1,8 @@
 localstack:
   services: sqs
   shared: true
+
+  aws:
+    sqs:
+      tags:
+        domain: Agorapulse
diff --git a/...sdk-sqs/src/main/groovy/com/agorapulse/micronaut/aws/sqs/DefaultSimpleQueueService.groovy b/...sdk-sqs/src/main/groovy/com/agorapulse/micronaut/aws/sqs/DefaultSimpleQueueService.groovy
@@ -94,6 +94,11 @@ class DefaultSimpleQueueService implements SimpleQueueService {
         if (configuration.fifo || configuration.queue.endsWith('.fifo')) {
             createQueueRequest.attributes['FifoQueue'] = 'true'
         }
+
+        if (configuration.tags) {
+            createQueueRequest.tags = configuration.tags
+        }
+
         String queueUrl = client.createQueue(createQueueRequest).queueUrl
         log.debug "Queue created (queueUrl=$queueUrl)"
         addQueue(queueUrl)

diff --git a/...naut-aws-sdk-sqs/src/main/groovy/com/agorapulse/micronaut/aws/sqs/QueueConfiguration.java b/...naut-aws-sdk-sqs/src/main/groovy/com/agorapulse/micronaut/aws/sqs/QueueConfiguration.java
@@ -19,6 +19,8 @@
 
 import javax.validation.constraints.Max;
 import javax.validation.constraints.Min;
+import java.util.LinkedHashMap;
+import java.util.Map;
 
 public class QueueConfiguration implements Cloneable {
     public QueueConfiguration withQueue(String queue) {
@@ -113,6 +115,14 @@ public void setVisibilityTimeout(Integer visibilityTimeout) {
         this.visibilityTimeout = visibilityTimeout;
     }
 
+    public Map<String, String> getTags() {
+        return tags;
+    }
+
+    public void setTags(Map<String, String> tags) {
+        this.tags = tags;
+    }
+
     private String queue = "";
     private boolean fifo;
 
@@ -131,4 +141,6 @@ public void setVisibilityTimeout(Integer visibilityTimeout) {
     @Min(0L)
     @Max(43200L)
     private Integer visibilityTimeout = 30;
+
+    private Map<String, String> tags = new LinkedHashMap<>();
 }
diff --git a/subprojects/micronaut-aws-sdk-sqs/src/test/resources/application-test.yml b/subprojects/micronaut-aws-sdk-sqs/src/test/resources/application-test.yml
@@ -1,3 +1,8 @@
 localstack:
   services: sqs
   shared: true
+
+aws:
+  sqs:
+    tags:
+      domain: Agorapulse