diff --git a/redisson/src/main/java/org/redisson/RedissonTopic.java b/redisson/src/main/java/org/redisson/RedissonTopic.java index 558097e72c4aa0f550d8c8a3eac5d121d6e35766..6be176ad0d92fdaeb0e0f35b0cf26342b47fed54 100644 --- a/redisson/src/main/java/org/redisson/RedissonTopic.java +++ b/redisson/src/main/java/org/redisson/RedissonTopic.java @@ -72,7 +72,7 @@ public class RedissonTopic implements RTopic { public RedissonTopic(Codec codec, CommandAsyncExecutor commandExecutor, NameMapper nameMapper, String name) { this.commandExecutor = commandExecutor; this.name = nameMapper.map(name); - this.channelName = new ChannelName(name); + this.channelName = new ChannelName(this.name); this.codec = codec; this.subscribeService = commandExecutor.getConnectionManager().getSubscribeService(); }