diff options
| author |  Tom van der Lee <tom@vanderlee.io> | 2026-04-28 10:45:41 +0200 |
|---|---|---|
| committer | Tom van der Lee <tom@vanderlee.io> | 2026-04-28 10:45:41 +0200 |
| commit | b8d5952b83e7601c5df646efd976879f0dbd30c2 (patch) | |
| tree | 6366e383f6fc484e96a7e618015374561452d841 /ttun_server/proxy_queue.py | |
| parent | d93199684f159d59ef62e4c90d16516f6fd9526e (diff) | |
| download | server-b8d5952b83e7601c5df646efd976879f0dbd30c2.tar.gz server-b8d5952b83e7601c5df646efd976879f0dbd30c2.tar.bz2 server-b8d5952b83e7601c5df646efd976879f0dbd30c2.zip | |
Fixed issue with the redis proxy queue not working due to enqueing on the wrong queuev2.2.1
Diffstat (limited to 'ttun_server/proxy_queue.py')
| -rw-r--r-- | ttun_server/proxy_queue.py | 2 |
1 files changed, 1 insertions, 1 deletions
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): | |||
| 109 | async def enqueue(self, message: Message): | 109 | async def enqueue(self, message: Message): |
| 110 | await RedisConnectionPool \ | 110 | await RedisConnectionPool \ |
| 111 | .get_connection() \ | 111 | .get_connection() \ |
| 112 | .publish(self.identifier, json.dumps(message)) | 112 | .publish(f'request_{self.identifier}', json.dumps(message)) |
| 113 | 113 | ||
| 114 | async def dequeue(self) -> Message: | 114 | async def dequeue(self) -> Message: |
| 115 | message = await self.wait_for_message() | 115 | message = await self.wait_for_message() |