Fixed - RDoubleAdder and RLongAdder don't work with nameMapper

redisson · Nov 8, 2022 · 4c6ef75 · 4c6ef75
1 parent edd644c
commit 4c6ef75
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/redisson/src/main/java/org/redisson/RedissonBaseAdder.java b/redisson/src/main/java/org/redisson/RedissonBaseAdder.java
@@ -44,10 +44,10 @@ public abstract class RedissonBaseAdder<T extends Number> extends RedissonExpira
     private final RTopic topic;
     private final int listenerId;
 
-    public RedissonBaseAdder(CommandAsyncExecutor connectionManager, String name, RedissonClient redisson) {
-        super(connectionManager, name);
+    public RedissonBaseAdder(CommandAsyncExecutor commandExecutor, String name, RedissonClient redisson) {
+        super(commandExecutor, name);
 
-        topic = redisson.getTopic(suffixName(getRawName(), "topic"), StringCodec.INSTANCE);
+        topic = RedissonTopic.createRaw(StringCodec.INSTANCE, commandExecutor, suffixName(getRawName(), "topic"));
         this.redisson = redisson;
         listenerId = topic.addListener(String.class, (channel, msg) -> {
             String[] parts = msg.split(":");