Comparing version 2.0.5 to 2.0.6
@@ -18,3 +18,3 @@ "use strict"; | ||
async initialize(topic) { | ||
var _a; | ||
var _a, _b; | ||
if (!topic) { | ||
@@ -37,5 +37,5 @@ throw new Error('Topic cannot be empty'); | ||
}; | ||
const { data: { QueueUrl }, } = await this.producer.createQueueAsync(params); | ||
this.sqsUrls[topic] = QueueUrl; | ||
return QueueUrl; | ||
let createResponse = await this.producer.createQueueAsync(params); | ||
this.sqsUrls[topic] = (_b = createResponse) === null || _b === void 0 ? void 0 : _b.QueueUrl; | ||
return this.sqsUrls[topic]; | ||
} | ||
@@ -42,0 +42,0 @@ getPayload(msg, topic) { |
{ | ||
"name": "steveo", | ||
"version": "2.0.5", | ||
"version": "2.0.6", | ||
"description": "A Task Pub/Sub Background processing library", | ||
@@ -5,0 +5,0 @@ "main": "lib/index.js", |
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
66788