refactoring

redisson-micronaut/redisson-micronaut-20/src/main/java/org/redisson/micronaut/session/RedissonSessionStore.java

@@ -245,7 +245,7 @@ public class RedissonSessionStore implements SessionStore<RedissonSession>, Patt
     }
 
     private RTopic getTopic(String name, Codec codec) {
-        PublishSubscribeService ss = ((Redisson) redisson).getConnectionManager().getSubscribeService();
+        PublishSubscribeService ss = ((Redisson) redisson).getCommandExecutor().getConnectionManager().getSubscribeService();
         if (ss.isShardingSupported()) {
             return redisson.getShardedTopic(name, codec);
         }

redisson-micronaut/redisson-micronaut-30/src/main/java/org/redisson/micronaut/session/RedissonSessionStore.java

@@ -245,7 +245,7 @@ public class RedissonSessionStore implements SessionStore<RedissonSession>, Patt
     }
 
     private RTopic getTopic(String name, Codec codec) {
-        PublishSubscribeService ss = ((Redisson) redisson).getConnectionManager().getSubscribeService();
+        PublishSubscribeService ss = ((Redisson) redisson).getCommandExecutor().getConnectionManager().getSubscribeService();
         if (ss.isShardingSupported()) {
             return redisson.getShardedTopic(name, codec);
         }

redisson-micronaut/redisson-micronaut-40/src/main/java/org/redisson/micronaut/session/RedissonSessionStore.java

@@ -245,7 +245,7 @@ public class RedissonSessionStore implements SessionStore<RedissonSession>, Patt
     }
 
     private RTopic getTopic(String name, Codec codec) {
-        PublishSubscribeService ss = ((Redisson) redisson).getConnectionManager().getSubscribeService();
+        PublishSubscribeService ss = ((Redisson) redisson).getCommandExecutor().getConnectionManager().getSubscribeService();
         if (ss.isShardingSupported()) {
             return redisson.getShardedTopic(name, codec);
         }

redisson-tomcat/redisson-tomcat-10/src/main/java/org/redisson/tomcat/RedissonSessionManager.java

@@ -159,7 +159,7 @@ public class RedissonSessionManager extends ManagerBase {
     public RTopic getTopic() {
         String separator = keyPrefix == null || keyPrefix.isEmpty() ? "" : ":";
         final String name = keyPrefix + separator + "redisson:tomcat_session_updates:" + getContext().getName();
-        PublishSubscribeService ss = ((Redisson) redisson).getConnectionManager().getSubscribeService();
+        PublishSubscribeService ss = ((Redisson) redisson).getCommandExecutor().getConnectionManager().getSubscribeService();
         if (ss.isShardingSupported()) {
             return redisson.getShardedTopic(name);
         }

redisson-tomcat/redisson-tomcat-11/src/main/java/org/redisson/tomcat/RedissonSessionManager.java

@@ -159,7 +159,7 @@ public class RedissonSessionManager extends ManagerBase {
     public RTopic getTopic() {
         String separator = keyPrefix == null || keyPrefix.isEmpty() ? "" : ":";
         final String name = keyPrefix + separator + "redisson:tomcat_session_updates:" + getContext().getName();
-        PublishSubscribeService ss = ((Redisson) redisson).getConnectionManager().getSubscribeService();
+        PublishSubscribeService ss = ((Redisson) redisson).getCommandExecutor().getConnectionManager().getSubscribeService();
         if (ss.isShardingSupported()) {
             return redisson.getShardedTopic(name);
         }

redisson-tomcat/redisson-tomcat-7/src/main/java/org/redisson/tomcat/RedissonSessionManager.java

@@ -159,7 +159,7 @@ public class RedissonSessionManager extends ManagerBase {
     public RTopic getTopic() {
         String separator = keyPrefix == null || keyPrefix.isEmpty() ? "" : ":";
         String name = keyPrefix + separator + "redisson:tomcat_session_updates:" + getContainer().getName();
-        PublishSubscribeService ss = ((Redisson) redisson).getConnectionManager().getSubscribeService();
+        PublishSubscribeService ss = ((Redisson) redisson).getCommandExecutor().getConnectionManager().getSubscribeService();
         if (ss.isShardingSupported()) {
             return redisson.getShardedTopic(name);
         }

redisson-tomcat/redisson-tomcat-8/src/main/java/org/redisson/tomcat/RedissonSessionManager.java

@@ -159,7 +159,7 @@ public class RedissonSessionManager extends ManagerBase {
     public RTopic getTopic() {
         String separator = keyPrefix == null || keyPrefix.isEmpty() ? "" : ":";
         final String name = keyPrefix + separator + "redisson:tomcat_session_updates:" + getContext().getName();
-        PublishSubscribeService ss = ((Redisson) redisson).getConnectionManager().getSubscribeService();
+        PublishSubscribeService ss = ((Redisson) redisson).getCommandExecutor().getConnectionManager().getSubscribeService();
         if (ss.isShardingSupported()) {
             return redisson.getShardedTopic(name);
         }

redisson-tomcat/redisson-tomcat-9/src/main/java/org/redisson/tomcat/RedissonSessionManager.java

@@ -167,7 +167,7 @@ public class RedissonSessionManager extends ManagerBase {
     public RTopic getTopic() {
         String separator = keyPrefix == null || keyPrefix.isEmpty() ? "" : ":";
         final String name = keyPrefix + separator + "redisson:tomcat_session_updates:" + getContext().getName();
-        PublishSubscribeService ss = ((Redisson) redisson).getConnectionManager().getSubscribeService();
+        PublishSubscribeService ss = ((Redisson) redisson).getCommandExecutor().getConnectionManager().getSubscribeService();
         if (ss.isShardingSupported()) {
             return redisson.getShardedTopic(name);
         }

redisson/src/main/java/org/redisson/RedissonNode.java

@@ -183,7 +183,7 @@ public final class RedissonNode {
     }
 
     private void retrieveAddresses() {
-        ConnectionManager connectionManager = ((Redisson) redisson).getConnectionManager();
+        ConnectionManager connectionManager = ((Redisson) redisson).getCommandExecutor().getConnectionManager();
         for (MasterSlaveEntry entry : connectionManager.getEntrySet()) {
             CompletionStage<RedisConnection> readFuture = entry.connectionReadOp(null, false);
             RedisConnection readConnection = null;