From 21bdc124c1cfbc4ca9e6791b52fc9064f80fc533 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Tue, 4 Apr 2017 12:05:41 +0200
Subject: wait for rabbit to start

---
 worker.js | 18 +++++++++++++-----
 1 file changed, 13 insertions(+), 5 deletions(-)

diff --git a/worker.js b/worker.js
index adf415c..99bb72d 100644
--- a/worker.js
+++ b/worker.js
@@ -12,13 +12,21 @@ var MADGLORY_TOKEN = process.env.MADGLORY_TOKEN,
 if (MADGLORY_TOKEN == undefined) throw "Need an API token";
 
 (async () => {
-    var rabbit = await amqp.connect(RABBITMQ_URI),
-        ch = await rabbit.createChannel();
+    let rabbit, ch;
 
-    await ch.assertQueue("grab", {durable: true});
-    await ch.assertQueue("process", {durable: true});
-    await ch.prefetch(1);
+    while (true) {
+        try {
+            rabbit = await amqp.connect(RABBITMQ_URI);
+            ch = await rabbit.createChannel();
+            await ch.assertQueue("grab", {durable: true});
+            await ch.assertQueue("process", {durable: true});
+        } catch (err) {
+            console.error(err);
+            await sleep(5000);
+        }
+    }
 
+    await ch.prefetch(1);
     ch.consume("grab", async (msg) => {
         let exhausted = false,
             payload = JSON.parse(msg.content);
-- 
cgit v1.3.1