summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorschneefux <schneefux+commit@schneefux.xyz>2017-04-14 09:37:43 +0200
committerschneefux <schneefux+commit@schneefux.xyz>2017-04-14 09:37:43 +0200
commitdc8b4f09a9ade53ccac37543e14abbbeda13bac1 (patch)
treef09bd1bcc0a7a5e3ad69eeb274b6982fbec27c9a
parent3a1bde411154856a821f2d9baa9d9e2c343ce8a0 (diff)
downloadshrinker-dc8b4f09a9ade53ccac37543e14abbbeda13bac1.tar.gz
shrinker-dc8b4f09a9ade53ccac37543e14abbbeda13bac1.zip
increase max pool size
-rw-r--r--worker.js5
1 files changed, 4 insertions, 1 deletions
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});