PROCESS_QUEUE -> SHRINK_QUEUE

1 files changed, 1 insertions, 1 deletions

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 }