chore: fix message count bug

hpcc-systems · Sep 11, 2024 · ddf76c3 · ddf76c3
1 parent 0362878
commit ddf76c3
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/packages/aws/stepDefinitions/sqs.js b/packages/aws/stepDefinitions/sqs.js
@@ -95,12 +95,12 @@ async function waitUntilQueueHasCount (queueName, messageCount, timeout) {
   let queueAttributes
   do {
     queueAttributes = await attributesOfQueue(queueName)
-    if (queueAttributes.ApproximateNumberOfMessages === '0') {
+    if (queueAttributes.ApproximateNumberOfMessages === messageCount.toString()) {
       return true
     }
     await new Promise(resolve => setTimeout(resolve, 5000))
   } while (Date.now() - startTime < timeout * 1000)
-  throw new Error('Queue is not empty within ' + timeout + ' seconds')
+  throw new Error('Queue ' + queueName + ' did not have ' + messageCount + ' messages within ' + timeout + ' seconds. Current message count: ' + queueAttributes.ApproximateNumberOfMessages)
 }
 
 MAFWhen('queue {string} is empty within {int} second(s)', async function (queueName, timeout) {