@altangent/aws-client
Advanced tools
Comparing version 1.3.1 to 1.3.2
@@ -103,6 +103,13 @@ "use strict"; | ||
while (keepRunning) { | ||
let results = yield exports.sqs | ||
.receiveMessage({ QueueUrl: queueUrl, MaxNumberOfMessages: 10 }) | ||
.promise(); | ||
callback(results.Messages); | ||
try { | ||
let results = yield exports.sqs | ||
.receiveMessage({ QueueUrl: queueUrl, MaxNumberOfMessages: 10 }) | ||
.promise(); | ||
callback(results.Messages); | ||
} | ||
catch (ex) { | ||
// this needs to be here incase we have an issue with the AWS-SDK | ||
// which occassionally happens. we want this loop to continue. | ||
winston.error(ex); | ||
} | ||
} | ||
@@ -109,0 +116,0 @@ }); |
{ | ||
"name": "@altangent/aws-client", | ||
"version": "1.3.1", | ||
"version": "1.3.2", | ||
"description": "AWS tools", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
@@ -115,6 +115,12 @@ import * as winston from 'winston'; | ||
while (keepRunning) { | ||
let results = await sqs | ||
.receiveMessage({ QueueUrl: queueUrl, MaxNumberOfMessages: 10 }) | ||
.promise(); | ||
callback(results.Messages); | ||
try { | ||
let results = await sqs | ||
.receiveMessage({ QueueUrl: queueUrl, MaxNumberOfMessages: 10 }) | ||
.promise(); | ||
callback(results.Messages); | ||
} catch (ex) { | ||
// this needs to be here incase we have an issue with the AWS-SDK | ||
// which occassionally happens. we want this loop to continue. | ||
winston.error(ex); | ||
} | ||
} | ||
@@ -121,0 +127,0 @@ } |
Sorry, the diff of this file is not supported yet
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
License Policy Violation
LicenseThis package is not allowed per your license policy. Review the package's license to ensure compliance.
Found 1 instance in 1 package
35908
805