From 9bcc17fc5b87ada9a7300ead72e381cee139a6b1 Mon Sep 17 00:00:00 2001 From: schneefux Date: Tue, 4 Apr 2017 12:04:03 +0200 Subject: assert queues & sleep longer --- server.js | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) 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); } } })(); -- cgit v1.3.1