consistent_hash parameter in the send method is incorrect

django · Sep 3, 2020 · 63575a0 · 63575a0
1 parent 2075071
commit 63575a0
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/channels_redis/core.py b/channels_redis/core.py
@@ -297,7 +297,7 @@ async def send(self, channel, message):
         # Pick a connection to the right server - consistent for specific
         # channels, random for general channels
         if "!" in channel:
-            index = self.consistent_hash(channel)
+            index = self.consistent_hash(channel_non_local_name)
         else:
             index = next(self._send_index_generator)
         async with self.connection(index) as connection: