Feature - LoadBalancer.getEntry(List<ClientConnectionsEntry> clientsCopy, RedisCommand<?> redisCommand) method added

redisson/src/main/java/org/redisson/connection/balancer/LoadBalancer.java

@@ -15,10 +15,11 @@
  */
 package org.redisson.connection.balancer;
 
-import java.util.List;
-
+import org.redisson.client.protocol.RedisCommand;
 import org.redisson.connection.ClientConnectionsEntry;
 
+import java.util.List;
+
 /**
  * 
  * @author Nikita Koksharov
@@ -26,6 +27,14 @@ import org.redisson.connection.ClientConnectionsEntry;
  */
 public interface LoadBalancer {
 
+    /*
+     * Use getEntry(List<ClientConnectionsEntry> clientsCopy, RedisCommand<?> redisCommand) method instead
+     */
+    @Deprecated
     ClientConnectionsEntry getEntry(List<ClientConnectionsEntry> clientsCopy);
 
+    default ClientConnectionsEntry getEntry(List<ClientConnectionsEntry> clientsCopy, RedisCommand<?> redisCommand) {
+        return getEntry(clientsCopy);
+    }
+
 }

redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java

@@ -186,7 +186,7 @@ abstract class ConnectionPool<T extends RedisConnection> {
             }
         }
         if (!entriesCopy.isEmpty()) {
-            ClientConnectionsEntry entry = config.getLoadBalancer().getEntry(entriesCopy);
+            ClientConnectionsEntry entry = config.getLoadBalancer().getEntry(entriesCopy, command);
             return acquireConnection(command, entry);
         }
         

redisson/src/main/java/org/redisson/connection/pool/PubSubConnectionPool.java

@@ -39,7 +39,7 @@ public class PubSubConnectionPool extends ConnectionPool<RedisPubSubConnection>
     }
 
     public CompletableFuture<RedisPubSubConnection> get() {
-        return get(RedisCommands.PUBLISH);
+        return get(RedisCommands.SUBSCRIBE);
     }
     
     @Override