diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-08-08 16:13:45 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-08-08 16:13:45 +0200 |
| commit | 435560ce5d0743bb6f5a57575a5683f51b0abb44 (patch) | |
| tree | 5ce7f5c132040c806e105365fda3c6d7bdc5ac93 | |
| parent | 043b5746fd33dea805afeb71a5158a72d9743e1f (diff) | |
| download | apigrabber-435560ce5d0743bb6f5a57575a5683f51b0abb44.tar.gz apigrabber-435560ce5d0743bb6f5a57575a5683f51b0abb44.zip | |
output config on bootrelease/2.17.0develop
| -rw-r--r-- | worker.js | 2 |
1 files changed, 2 insertions, 0 deletions
@@ -43,6 +43,8 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => { await ch.assertQueue(PROCESS_QUEUE, { durable: true }); await ch.prefetch(1); // 1 worker = 1 grab job + logger.info("configuration", { QUEUE, PROCESS_QUEUE }); + // main queue ch.consume(QUEUE, async (msg) => { try { |
