summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-04-13 15:58:34 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-04-13 15:58:34 +0200
commitf69cbf7d1891127358120ea52ca19e71f55a4940 (patch)
tree43f6bdb40bfc9780d5f1235bc7771f214d36aed0
parentf12f22453d03546b01e3cd7399fb1ce62f0cc128 (diff)
downloadshrinker-f69cbf7d1891127358120ea52ca19e71f55a4940.tar.gz
shrinker-f69cbf7d1891127358120ea52ca19e71f55a4940.zip
increase heartbeat duration
-rw-r--r--worker.js2
1 files changed, 1 insertions, 1 deletions
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});