diff --git a/channels_redis/core.py b/channels_redis/core.py index cde79627..685793b8 100644 --- 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: