Skip to content

Commit d367cc4

Browse files
Add support for forcing tag update (#218)
* Add support for forcing tag update * Finishing SQS tag update tests * Minor test improvement * lint fix * Fixing missing piece on SNS * sns sqs consumer update tags tests * Minor improvements * Minor test simplification * SQS publisher tests * Release prepare --------- Co-authored-by: CarlosGamero <[email protected]>
1 parent 2252912 commit d367cc4

File tree

10 files changed

+640
-279
lines changed

10 files changed

+640
-279
lines changed

packages/sns/lib/utils/snsInitter.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -69,6 +69,7 @@ export async function initSnsSqs(
6969
allowedSourceOwner: creationConfig.allowedSourceOwner,
7070
topicArnsWithPublishPermissionsPrefix: creationConfig.topicArnsWithPublishPermissionsPrefix,
7171
logger: extraParams?.logger,
72+
forceTagUpdate: creationConfig.forceTagUpdate,
7273
},
7374
)
7475
if (!subscriptionArn) {

packages/sns/lib/utils/snsSubscriber.ts

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -55,6 +55,7 @@ export async function subscribeToTopic(
5555
const { queueUrl, queueArn } = await assertQueue(sqsClient, queueConfiguration, {
5656
topicArnsWithPublishPermissionsPrefix: extraParams?.topicArnsWithPublishPermissionsPrefix,
5757
updateAttributesIfExists: extraParams?.updateAttributesIfExists,
58+
forceTagUpdate: extraParams?.forceTagUpdate,
5859
})
5960

6061
const subscribeCommand = new SubscribeCommand({

packages/sns/package.json

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1,6 +1,6 @@
11
{
22
"name": "@message-queue-toolkit/sns",
3-
"version": "17.2.0",
3+
"version": "17.3.0",
44
"private": false,
55
"license": "MIT",
66
"description": "SNS adapter for message-queue-toolkit",

0 commit comments

Comments
 (0)