We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
2 parents d6014e4 + c62de20 commit a8e04b4Copy full SHA for a8e04b4
src/sqs.js
@@ -39,7 +39,14 @@ const createClient = (sqs) => {
39
const moveMessage = (sourceQueueUrl, targetQueueUrl) => (
40
new Promise(async (resolve, reject) => {
41
try {
42
- const { Body, ReceiptHandle } = await receiveMessage(sourceQueueUrl);
+ const receivedMessage = await receiveMessage(sourceQueueUrl);
43
+
44
+ if (!receivedMessage.Body || !receivedMessage.ReceiptHandle) {
45
+ throw 'Queue is empty'; // eslint-disable-line
46
+ }
47
48
+ const { Body, ReceiptHandle } = receivedMessage;
49
50
await sendMessage(targetQueueUrl, Body);
51
await deleteMessage(sourceQueueUrl, ReceiptHandle);
52
0 commit comments