From 8fc543cd4773965a231b8b00e80730f5130fedd4 Mon Sep 17 00:00:00 2001 From: schneefux Date: Tue, 8 Aug 2017 16:22:03 +0200 Subject: output config on boot, assert analyze queue --- worker.js | 6 ++++++ 1 file changed, 6 insertions(+) diff --git a/worker.js b/worker.js index 32b0859..f5531d8 100644 --- a/worker.js +++ b/worker.js @@ -105,12 +105,18 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { const ch = await rabbit.createChannel(); await ch.assertQueue(QUEUE, { durable: true }); await ch.assertQueue(QUEUE + "_failed", { durable: true }); + await ch.assertQueue(ANALYZE_QUEUE, { durable: true }); // as long as the queue is filled, msg are not ACKed // server sends as long as there are less than `prefetch` unACKed await ch.prefetch(BATCHSIZE); const model = require("../orm/model")(seq, Seq); + logger.info("configuration", { + QUEUE, BATCHSIZE, CHUNKSIZE, MAXCONNS, LOAD_TIMEOUT, IDLE_TIMEOUT, + DOANALYZEMATCH, ANALYZE_QUEUE + }); + // performance logging let load_timer = undefined, idle_timer = undefined, -- cgit v1.3.1