assert queues & sleep longer

1 files changed, 3 insertions, 1 deletions

diff --git a/server.js b/server.js
index 59b3c89..4a0ec4c 100644
--- a/server.js
+++ b/server.js
@@ -24,10 +24,12 @@ var rabbit,
         try {
             rabbit = await amqp.connect(RABBITMQ_URI);
             ch = await rabbit.createChannel();
+            await ch.assertQueue("grab", {durable: true});
+            await ch.assertQueue("process", {durable: true});
             return;
         } catch (err) {
             console.error(err);
-            await sleep(1000);
+            await sleep(5000);
         }
     }
 })();