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):
    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()

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()