aws-fanout
Advanced tools
Comparing version 1.1.5 to 1.1.6
@@ -83,3 +83,3 @@ 'use strict'; | ||
var deleteMessage = function deleteMessage(credentials, queueName, receiptHandle) { | ||
return getQueueUrl(credentials, queueName).then(function (url) { | ||
return (0, _sqsGetQueueInfo.getSqsUrl)(credentials, queueName).then(function (url) { | ||
return (0, _sqsDeleteMessage2['default'])(credentials, url, receiptHandle); | ||
@@ -97,3 +97,3 @@ }); | ||
var receiveMessage = function receiveMessage(credentials, maxMessages, visibilityTimeout, queueName) { | ||
return getQueueUrl(credentials, queueName).then(function (url) { | ||
return (0, _sqsGetQueueInfo.getSqsUrl)(credentials, queueName).then(function (url) { | ||
return (0, _sqsReceiveMessage2['default'])(credentials, maxMessages, visibilityTimeout, url); | ||
@@ -100,0 +100,0 @@ }); |
@@ -70,3 +70,3 @@ import Promise from 'bluebird' | ||
const deleteMessage = (credentials, queueName, receiptHandle) => { | ||
return getQueueUrl(credentials, queueName) | ||
return getSqsUrl(credentials, queueName) | ||
.then(url => deleteSqsMessage(credentials, url, receiptHandle)) | ||
@@ -83,3 +83,3 @@ } | ||
const receiveMessage = (credentials, maxMessages, visibilityTimeout, queueName) => { | ||
return getQueueUrl(credentials, queueName) | ||
return getSqsUrl(credentials, queueName) | ||
.then(url => receiveSqsMessage(credentials, maxMessages, visibilityTimeout, url)) | ||
@@ -86,0 +86,0 @@ } |
@@ -22,3 +22,3 @@ import { SNS } from 'aws-sdk' | ||
const sns = new SNS(credentials) | ||
return new Promise((resolve, reject) => { | ||
@@ -25,0 +25,0 @@ sns.subscribe({ |
{ | ||
"name": "aws-fanout", | ||
"version": "1.1.5", | ||
"version": "1.1.6", | ||
"description": "A library wrapping SNS and SQS to allow for human readable names when using a fanout technique", | ||
@@ -5,0 +5,0 @@ "main": "dist/index.js", |
35813