diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-14 09:37:43 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-04-14 09:37:43 +0200 |
| commit | dc8b4f09a9ade53ccac37543e14abbbeda13bac1 (patch) | |
| tree | f09bd1bcc0a7a5e3ad69eeb274b6982fbec27c9a /worker.js | |
| parent | 3a1bde411154856a821f2d9baa9d9e2c343ce8a0 (diff) | |
| download | processor-dc8b4f09a9ade53ccac37543e14abbbeda13bac1.tar.gz processor-dc8b4f09a9ade53ccac37543e14abbbeda13bac1.zip | |
increase max pool size
Diffstat (limited to 'worker.js')
| -rw-r--r-- | worker.js | 5 |
1 files changed, 4 insertions, 1 deletions
@@ -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}); |
