From 3785ed862accad4c8f8b7e719d86aabb0506e36d Mon Sep 17 00:00:00 2001 From: schneefux Date: Sat, 15 Apr 2017 15:18:04 +0200 Subject: scale apigrabber --- worker.js | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/worker.js b/worker.js index 634afca..a49985a 100644 --- a/worker.js +++ b/worker.js @@ -9,7 +9,8 @@ var amqp = require("amqplib"), AdmZip = require("adm-zip"); var MADGLORY_TOKEN = process.env.MADGLORY_TOKEN, - RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost"; + RABBITMQ_URI = process.env.RABBITMQ_URI || "amqp://localhost", + GRABBERS = parseInt(process.env.GRABBERS) || 4; if (MADGLORY_TOKEN == undefined) throw "Need an API token"; (async () => { @@ -29,7 +30,7 @@ if (MADGLORY_TOKEN == undefined) throw "Need an API token"; } } - await ch.prefetch(1); + await ch.prefetch(GRABBERS); ch.consume("grab", async (msg) => { let payload = JSON.parse(msg.content.toString()), notify = msg.properties.headers.notify; // where to send progress report -- cgit v1.3.1