feat: increase lambda worker default message retention period (#79)

techfromsage · Aug 14, 2023 · 4c7bd4d · 4c7bd4d
1 parent 846ce58
commit 4c7bd4d
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 0 deletions.
diff --git a/lib/lambda-worker/lambda-worker.ts b/lib/lambda-worker/lambda-worker.ts
@@ -89,6 +89,7 @@ export class LambdaWorker extends cdk.Construct {
     const lambdaDLQ = new sqs.Queue(this, `${props.name}-dlq`, {
       queueName: dlqName,
       visibilityTimeout: queueTimeout,
+      retentionPeriod: cdk.Duration.days(14),
       fifo: fifo ? true : undefined, // This is required for fifo, but has to be undefined not flase for non-fifo
     });
 
@@ -99,6 +100,7 @@ export class LambdaWorker extends cdk.Construct {
     const lambdaQueue = new sqs.Queue(this, `${props.name}-queue`, {
       queueName,
       visibilityTimeout: queueTimeout,
+      retentionPeriod: cdk.Duration.days(14),
       deadLetterQueue: { queue: lambdaDLQ, maxReceiveCount: maxReceiveCount },
       fifo: fifo ? true : undefined, // This is required for fifo, but has to be undefined not flase for non-fifo
       contentBasedDeduplication:

diff --git a/test/infra/lambda-worker/lambda-worker.test.ts b/test/infra/lambda-worker/lambda-worker.test.ts
@@ -90,6 +90,7 @@ describe("LambdaWorker", () => {
           haveResourceLike("AWS::SQS::Queue", {
             QueueName: "MyTestLambdaWorker-queue",
             VisibilityTimeout: 1500, // 5 (default max receive count) * 300 (lambda timeout)
+            MessageRetentionPeriod: 1209600, // 14 days
             RedrivePolicy: {
               maxReceiveCount: 5,
               deadLetterTargetArn: {
@@ -106,6 +107,7 @@ describe("LambdaWorker", () => {
           haveResourceLike("AWS::SQS::Queue", {
             QueueName: "MyTestLambdaWorker-dlq",
             VisibilityTimeout: 1500, // 5 (default max receive count) * 300 (lambda timeout)
+            MessageRetentionPeriod: 1209600, // 14 days
           })
         );
       });