diff --git a/channels_redis/core.py b/channels_redis/core.py index 84cec2f..5f0e48e 100644 --- a/channels_redis/core.py +++ b/channels_redis/core.py @@ -313,7 +313,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: