diff options
| author | schneefux <schneefux+commit@schneefux.xyz> | 2017-08-08 16:08:23 +0200 |
|---|---|---|
| committer | schneefux <schneefux+commit@schneefux.xyz> | 2017-08-08 16:08:23 +0200 |
| commit | c5eed73d5f1f02e99bce7029a2c3b86c14a15fdd (patch) | |
| tree | e4531965f32b0b68288c81e7d29bed3492d8e103 | |
| parent | 60d5d177c2c2a7f3bfaae2148001400061232311 (diff) | |
| download | telesucker-c5eed73d5f1f02e99bce7029a2c3b86c14a15fdd.tar.gz telesucker-c5eed73d5f1f02e99bce7029a2c3b86c14a15fdd.zip | |
assert shrink queue
| -rw-r--r-- | worker.js | 1 |
1 files changed, 1 insertions, 0 deletions
@@ -42,6 +42,7 @@ 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(SHRINK_QUEUE, { durable: true }); await ch.prefetch(1); ch.consume(QUEUE, async (msg) => { |