From 6214af690fb273fcb1aeb9bf30813051fb05e633 Mon Sep 17 00:00:00 2001
From: schneefux <schneefux+commit@schneefux.xyz>
Date: Tue, 25 Jul 2017 20:13:07 +0200
Subject: PROCESS_QUEUE -> SHRINK_QUEUE

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

diff --git a/worker.js b/worker.js
index 18de020..de5a341 100644
--- a/worker.js
+++ b/worker.js
@@ -106,7 +106,7 @@ amqp.connect(RABBITMQ_URI).then(async (rabbit) => {
             if (phase.data.length > 0) {
                 const notify = "match." + match_api_id;
                 await ch.publish("amq.topic", notify, new Buffer("phase_pending"));
-                await ch.sendToQueue(PROCESS_QUEUE, new Buffer(
+                await ch.sendToQueue(SHRINK_QUEUE, new Buffer(
                     JSON.stringify(phase)), {
                         persistent: true, type: "telemetry",
                         headers: { notify }
-- 
cgit v1.3.1