From afd167555f3fd2eadccbf02608b1f58c68447a1b Mon Sep 17 00:00:00 2001 From: musketyr Date: Tue, 30 Jul 2024 14:41:05 +0200 Subject: [PATCH] include tags on queue configuration copy --- .../micronaut/amazon/awssdk/sqs/QueueConfiguration.java | 8 +++++++- .../agorapulse/micronaut/aws/sqs/QueueConfiguration.java | 8 +++++++- 2 files changed, 14 insertions(+), 2 deletions(-) diff --git a/subprojects/micronaut-amazon-awssdk-sqs/src/main/java/com/agorapulse/micronaut/amazon/awssdk/sqs/QueueConfiguration.java b/subprojects/micronaut-amazon-awssdk-sqs/src/main/java/com/agorapulse/micronaut/amazon/awssdk/sqs/QueueConfiguration.java index 5a8f029d6..d6068208d 100644 --- a/subprojects/micronaut-amazon-awssdk-sqs/src/main/java/com/agorapulse/micronaut/amazon/awssdk/sqs/QueueConfiguration.java +++ b/subprojects/micronaut-amazon-awssdk-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 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/subprojects/micronaut-aws-sdk-sqs/src/main/groovy/com/agorapulse/micronaut/aws/sqs/QueueConfiguration.java b/subprojects/micronaut-aws-sdk-sqs/src/main/groovy/com/agorapulse/micronaut/aws/sqs/QueueConfiguration.java index 698cffe0a..ab1958901 100644 --- a/subprojects/micronaut-aws-sdk-sqs/src/main/groovy/com/agorapulse/micronaut/aws/sqs/QueueConfiguration.java +++ b/subprojects/micronaut-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 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() {