include tags on queue configuration copy

agorapulse · Jul 30, 2024 · afd1675 · afd1675
1 parent f7e0ef9
commit afd1675
Show file tree

Hide file tree

Showing 2 changed files with 14 additions and 2 deletions.
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
@@ -58,6 +58,11 @@ public QueueConfiguration withVisibilityTimeout(Integer visibilityTimeout) {
         return this;
     }
 
+    private QueueConfiguration withTags(Map<String, String> tags) {
+        this.tags = tags;
+        return this;
+    }
+
     public QueueConfiguration copy() {
         return new QueueConfiguration()
             .withQueue(queue)
@@ -66,7 +71,8 @@ public QueueConfiguration copy() {
             .withDelaySeconds(delaySeconds)
             .withMessageRetentionPeriod(messageRetentionPeriod)
             .withMaximumMessageSize(maximumMessageSize)
-            .withVisibilityTimeout(visibilityTimeout);
+            .withVisibilityTimeout(visibilityTimeout)
+            .withTags(tags);
     }
 
     public String getQueue() {

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
@@ -58,6 +58,11 @@ public QueueConfiguration withVisibilityTimeout(Integer visibilityTimeout) {
         return this;
     }
 
+    public QueueConfiguration withTags(Map<String, String> tags) {
+        this.tags = tags;
+        return this;
+    }
+
     public QueueConfiguration copy() {
         return new QueueConfiguration()
             .withQueue(queue)
@@ -66,7 +71,8 @@ public QueueConfiguration copy() {
             .withDelaySeconds(delaySeconds)
             .withMessageRetentionPeriod(messageRetentionPeriod)
             .withMaximumMessageSize(maximumMessageSize)
-            .withVisibilityTimeout(visibilityTimeout);
+            .withVisibilityTimeout(visibilityTimeout)
+            .withTags(tags);
     }
 
     public String getQueue() {