Skip to content
Merged
Show file tree
Hide file tree
Changes from 1 commit
Commits
File filter

Filter by extension

Filter by extension

Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
1 change: 1 addition & 0 deletions packages/parser/src/schemas/sqs.ts
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ const SqsAttributesSchema = z.object({
SentTimestamp: z.string(),
SequenceNumber: z.string().optional(),
AWSTraceHeader: z.string().optional(),
DeadLetterQueueSourceArn: z.string().optional(), // Undocumented, but used by AWS to support their re-drive functionality in the console
});

const SqsRecordSchema = z.object({
Expand Down
3 changes: 2 additions & 1 deletion packages/parser/tests/events/sqsEvent.json
Original file line number Diff line number Diff line change
Expand Up @@ -30,7 +30,8 @@
"ApproximateReceiveCount": "1",
"SentTimestamp": "1545082650636",
"SenderId": "AIDAIENQZJOLO23YVJ4VO",
"ApproximateFirstReceiveTimestamp": "1545082650649"
"ApproximateFirstReceiveTimestamp": "1545082650649",
"DeadLetterQueueSourceArn": "arn:aws:sqs:us-east-2:123456789012:my-queue-dead"
},
"messageAttributes": {},
"md5OfBody": "e4e68fb7bd0e697a0ae8f1bb342846b3",
Expand Down