From 78273446460c7b4d94060f70255ba244ac40bb33 Mon Sep 17 00:00:00 2001 From: schneefux Date: Thu, 13 Apr 2017 12:58:17 +0200 Subject: heartbeat --- worker.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/worker.js b/worker.js index 90d8274..cbeb311 100644 --- a/worker.js +++ b/worker.js @@ -40,7 +40,7 @@ function snakeCaseKeys(obj) { while (true) { try { seq = new Seq(DATABASE_URI, { logging: () => {} }); - rabbit = await amqp.connect(RABBITMQ_URI); + rabbit = await amqp.connect(RABBITMQ_URI, { heartbeat: 30 }); ch = await rabbit.createChannel(); await ch.assertQueue("process", {durable: true}); await ch.assertQueue("crunch", {durable: true}); -- cgit v1.3.1