diff --git a/src/queue-wrapper.js b/src/queue-wrapper.js index ccff8302..1565e96f 100644 --- a/src/queue-wrapper.js +++ b/src/queue-wrapper.js @@ -24,7 +24,7 @@ export default function queueWrapper(func) { throw new Error('AUDIT_RESULTS_QUEUE_URL env variable is empty/not provided'); } - context.queue = SqsQueue(region, queueUrl, log); + context.queue = new SqsQueue(region, queueUrl, log); return func(request, context); };