summaryrefslogtreecommitdiff
path: root/worker.js
diff options
context:
space:
mode:
Diffstat (limited to 'worker.js')
-rw-r--r--worker.js2
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 }