From f69cbf7d1891127358120ea52ca19e71f55a4940 Mon Sep 17 00:00:00 2001 From: schneefux Date: Thu, 13 Apr 2017 15:58:34 +0200 Subject: increase heartbeat duration --- worker.js | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/worker.js b/worker.js index cda66cd..d6b0413 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, { heartbeat: 30 }); + rabbit = await amqp.connect(RABBITMQ_URI, { heartbeat: 120 }); ch = await rabbit.createChannel(); await ch.assertQueue("process", {durable: true}); await ch.assertQueue("analyze", {durable: true}); -- cgit v1.3.1