diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-13 15:58:34 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-13 15:58:34 +0200 |
| commit | f69cbf7d1891127358120ea52ca19e71f55a4940 (patch) | |
| tree | 43f6bdb40bfc9780d5f1235bc7771f214d36aed0 | |
| parent | f12f22453d03546b01e3cd7399fb1ce62f0cc128 (diff) | |
| download | shrinker-f69cbf7d1891127358120ea52ca19e71f55a4940.tar.gz shrinker-f69cbf7d1891127358120ea52ca19e71f55a4940.zip | |
increase heartbeat duration
| -rw-r--r-- | worker.js | 2 |
1 files changed, 1 insertions, 1 deletions
@@ -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}); |
