From dc8b4f09a9ade53ccac37543e14abbbeda13bac1 Mon Sep 17 00:00:00 2001 From: schneefux Date: Fri, 14 Apr 2017 09:37:43 +0200 Subject: increase max pool size --- worker.js | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) (limited to 'worker.js') diff --git a/worker.js b/worker.js index 1f5a549..f11c3e5 100644 --- a/worker.js +++ b/worker.js @@ -37,7 +37,10 @@ function snakeCaseKeys(obj) { while (true) { try { - seq = new Seq(DATABASE_URI, { logging: () => {} }); + seq = new Seq(DATABASE_URI, { + logging: false, + max: 10 + }); rabbit = await amqp.connect(RABBITMQ_URI, { heartbeat: 120 }); ch = await rabbit.createChannel(); await ch.assertQueue("process", {durable: true}); -- cgit v1.3.1