refactoring

redisson/src/main/java/org/redisson/api/RBatchReactive.java

@@ -286,9 +286,9 @@ public interface RBatchReactive {
      * @param name - name of object
      * @return Deque object
      */
-    <V> RDequeReactive<V> getDequeReactive(String name);
+    <V> RDequeReactive<V> getDeque(String name);
 
-    <V> RDequeReactive<V> getDequeReactive(String name, Codec codec);
+    <V> RDequeReactive<V> getDeque(String name, Codec codec);
 
     /**
      * Returns "atomic long" instance by name.
@@ -296,7 +296,7 @@ public interface RBatchReactive {
      * @param name - name of object
      * @return AtomicLong object
      */
-    RAtomicLongReactive getAtomicLongReactive(String name);
+    RAtomicLongReactive getAtomicLong(String name);
 
     /**
      * Returns atomicDouble instance by name.

redisson/src/main/java/org/redisson/reactive/RedissonBatchReactive.java

@@ -40,6 +40,7 @@ import org.redisson.RedissonSet;
 import org.redisson.RedissonSetCache;
 import org.redisson.RedissonSetMultimap;
 import org.redisson.RedissonStream;
+import org.redisson.RedissonTopic;
 import org.redisson.api.BatchOptions;
 import org.redisson.api.BatchResult;
 import org.redisson.api.RAtomicDoubleReactive;
@@ -180,12 +181,12 @@ public class RedissonBatchReactive implements RBatchReactive {
 
     @Override
     public <M> RTopicReactive<M> getTopic(String name) {
-        return new RedissonTopicReactive<M>(executorService, name);
+        return ReactiveProxyBuilder.create(executorService, new RedissonTopic<M>(executorService, name), RTopicReactive.class);
     }
 
     @Override
     public <M> RTopicReactive<M> getTopic(String name, Codec codec) {
-        return new RedissonTopicReactive<M>(codec, executorService, name);
+        return ReactiveProxyBuilder.create(executorService, new RedissonTopic<M>(codec, executorService, name), RTopicReactive.class);
     }
 
     @Override
@@ -213,19 +214,19 @@ public class RedissonBatchReactive implements RBatchReactive {
     }
 
     @Override
-    public <V> RDequeReactive<V> getDequeReactive(String name) {
+    public <V> RDequeReactive<V> getDeque(String name) {
         return ReactiveProxyBuilder.create(executorService, new RedissonDeque<V>(executorService, name, null), 
                 new RedissonListReactive<V>(executorService, name), RDequeReactive.class);
     }
 
     @Override
-    public <V> RDequeReactive<V> getDequeReactive(String name, Codec codec) {
+    public <V> RDequeReactive<V> getDeque(String name, Codec codec) {
         return ReactiveProxyBuilder.create(executorService, new RedissonDeque<V>(codec, executorService, name, null), 
                 new RedissonListReactive<V>(codec, executorService, name), RDequeReactive.class);
     }
 
     @Override
-    public RAtomicLongReactive getAtomicLongReactive(String name) {
+    public RAtomicLongReactive getAtomicLong(String name) {
         return ReactiveProxyBuilder.create(executorService, new RedissonAtomicLong(executorService, name), RAtomicLongReactive.class);
     }
 

redisson/src/main/java/org/redisson/reactive/RedissonLexSortedSetReactive.java

@@ -53,10 +53,6 @@ public class RedissonLexSortedSetReactive {
         };
     }
 
-    public String getName() {
-        return ((RedissonScoredSortedSet)instance).getName();
-    }
-    
     public Publisher<String> iterator() {
         return scanIteratorReactive(null, 10);
     }