summary refs log tree commit diff
diff options
context:
space:
mode:
authordank074 <torresefrain10@gmail.com>2026-02-01 23:21:36 -0600
committerdank074 <torresefrain10@gmail.com>2026-02-01 23:21:36 -0600
commitd9485d9597e1b2a182ef3639dbb81daca31b083a (patch)
treecebaec0dcbff9d80e304c84f7c0bbecbed5f0d7e
parentremove jitter from delay calculation altogether (diff)
downloadserver-ts-d9485d9597e1b2a182ef3639dbb81daca31b083a.tar.xz
don't need this
-rw-r--r--src/util/util/Event.ts4
1 files changed, 1 insertions, 3 deletions
diff --git a/src/util/util/Event.ts b/src/util/util/Event.ts

index cce72e7e..f72bb405 100644 --- a/src/util/util/Event.ts +++ b/src/util/util/Event.ts
@@ -81,8 +81,6 @@ export async function initEvent() { // Set up the spacebar event listener (used for config reload, etc.) const setupSpacebarListener = async () => { - if (!RabbitMQ.connection) return; - console.log("[Event] Setting up spacebar event listener"); await listenEvent("spacebar", async (event) => { console.log("[Event] Received spacebar event:", event); @@ -176,7 +174,7 @@ async function rabbitListen(channel: Channel, id: string, callback: (event: Even const cancel = async () => { try { - // Order matters here to prevent RESOURCE_ERROR: + // Order matters here to prevent RESOURCE_ERROR, due to potential race condition: // 1. Unbind first - stops new messages from being routed to this queue await channel.unbindQueue(q.queue, id, ""); // 2. Cancel consumer - with autoDelete: true, this triggers queue deletion