From b8d5952b83e7601c5df646efd976879f0dbd30c2 Mon Sep 17 00:00:00 2001
From: Tom van der Lee <tom@vanderlee.io>
Date: Tue, 28 Apr 2026 10:45:41 +0200
Subject: Fixed issue with the redis proxy queue not working due to enqueing on
 the wrong queue

---
 ttun_server/proxy_queue.py | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

(limited to 'ttun_server/proxy_queue.py')

diff --git a/ttun_server/proxy_queue.py b/ttun_server/proxy_queue.py
index c6c8067..cfa0f3c 100644
--- a/ttun_server/proxy_queue.py
+++ b/ttun_server/proxy_queue.py
@@ -109,7 +109,7 @@ class RedisProxyQueue(BaseProxyQueue):
     async def enqueue(self, message: Message):
         await RedisConnectionPool \
             .get_connection() \
-            .publish(self.identifier, json.dumps(message))
+            .publish(f'request_{self.identifier}', json.dumps(message))
 
     async def dequeue(self) -> Message:
         message = await self.wait_for_message()
-- 
cgit v1.2.3