From c5eed73d5f1f02e99bce7029a2c3b86c14a15fdd Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Tue, 8 Aug 2017 16:08:23 +0200
Subject: assert shrink queue

---
 worker.js | 1 +
 1 file changed, 1 insertion(+)

diff --git a/worker.js b/worker.js
index c411c6d..cd937b0 100644
--- a/worker.js
+++ b/worker.js
@@ -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) => {
-- 
cgit v1.3.1