Skip to content

Commit

Permalink
updating deps
Browse files Browse the repository at this point in the history
  • Loading branch information
mbonig committed Aug 25, 2020
1 parent ece6748 commit a9777d3
Show file tree
Hide file tree
Showing 3 changed files with 221 additions and 971 deletions.
6 changes: 2 additions & 4 deletions lib/sqs-redrive.queue-redrive.ts
Original file line number Diff line number Diff line change
@@ -1,5 +1,3 @@
import { DeleteMessageRequest, SendMessageRequest } from "aws-sdk/clients/sqs";

const aws = require('aws-sdk');
const sqs = new aws.SQS();
export const handler = async (event: any) => {
Expand All @@ -24,15 +22,15 @@ export const handler = async (event: any) => {
console.log(`RECEIVED ${DLQMessages.Messages.length} MESSAGES`);
for (const message of DLQMessages.Messages) {
// Send message to original queue
const outboundMessage: SendMessageRequest = {
const outboundMessage: any = {
MessageBody: message.Body as string,
QueueUrl: process.env.QUEUE_URL as string
};
console.log(`SENDING: ${JSON.stringify(outboundMessage, null, 2)}`);
await sqs.sendMessage(outboundMessage).promise();
console.log('SEND MESSAGE SUCCEEDED');
// Delete message from DLQ
const deleteParams: DeleteMessageRequest = {
const deleteParams: any = {
QueueUrl: process.env.DLQ_URL as string,
ReceiptHandle: message.ReceiptHandle as string
};
Expand Down
Loading

0 comments on commit a9777d3

Please sign in to comment.