🐛 Wait for queue to be created

staart · Feb 29, 2020 · 3235c24 · 3235c24
1 parent 76403fc
commit 3235c24
Show file tree

Hide file tree

Showing 4 changed files with 5 additions and 5 deletions.
diff --git a/package.json b/package.json
@@ -1,6 +1,6 @@
 {
   "name": "@staart/manager",
-  "version": "1.3.44",
+  "version": "1.3.45",
   "main": "index.js",
   "repository": "[email protected]:staart/api.git",
   "author": "Anand Chowdhary <[email protected]>",
@@ -125,5 +125,5 @@
     "setup"
   ],
   "snyk": true,
-  "staart-version": "1.3.44"
+  "staart-version": "1.3.45"
 }
diff --git a/src/helpers/elasticsearch.ts b/src/helpers/elasticsearch.ts
@@ -10,7 +10,7 @@ const setupQueue = async () => {
   if (queueSetup) return true;
   const queues = redisQueue.listQueuesAsync();
   if ((await queues).includes(ELASTIC_QUEUE)) return (queueSetup = true);
-  redisQueue.createQueueAsync({ qname: ELASTIC_QUEUE });
+  await redisQueue.createQueueAsync({ qname: ELASTIC_QUEUE });
   return (queueSetup = true);
 };
 

diff --git a/src/helpers/mail.ts b/src/helpers/mail.ts
@@ -14,7 +14,7 @@ const setupQueue = async () => {
   if (queueSetup) return true;
   const queues = redisQueue.listQueuesAsync();
   if ((await queues).includes(MAIL_QUEUE)) return (queueSetup = true);
-  redisQueue.createQueueAsync({ qname: MAIL_QUEUE });
+  await redisQueue.createQueueAsync({ qname: MAIL_QUEUE });
   return (queueSetup = true);
 };
 

diff --git a/src/helpers/webhooks.ts b/src/helpers/webhooks.ts
@@ -17,7 +17,7 @@ const setupQueue = async () => {
   if (queueSetup) return true;
   const queues = redisQueue.listQueuesAsync();
   if ((await queues).includes(WEBHOOK_QUEUE)) return (queueSetup = true);
-  redisQueue.createQueueAsync({ qname: WEBHOOK_QUEUE });
+  await redisQueue.createQueueAsync({ qname: WEBHOOK_QUEUE });
   return (queueSetup = true);
 };