Merge branch 'release-0.10.1'

erxes · Aug 19, 2019 · f70bfca · f70bfca
2 parents eeccf20 + cc51ca5
commit f70bfca
Showing 1 changed file with 5 additions and 3 deletions.
diff --git a/src/messageQueue.ts b/src/messageQueue.ts
@@ -62,9 +62,11 @@ const initConsumer = async () => {
 
     await channel.assertQueue('erxes-api:run-integrations-cronjob');
 
-    channel.consume('erxes-api:run-integrations-cronjob', async () => {
-      await handleRunCronMessage();
-      channel.ack();
+    channel.consume('erxes-api:run-integrations-cronjob', async msg => {
+      if (msg) {
+        await handleRunCronMessage();
+        channel.ack(msg);
+      }
     });
   } catch (e) {
     debugBase(e.message);