diff --git a/redisson/src/main/java/org/redisson/connection/balancer/LoadBalancer.java b/redisson/src/main/java/org/redisson/connection/balancer/LoadBalancer.java
index dc767ded0..42e08698d 100644
--- a/redisson/src/main/java/org/redisson/connection/balancer/LoadBalancer.java
+++ b/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);
+    }
+
 }
diff --git a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java b/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java
index 5a4bcd3b2..509e1d8f6 100644
--- a/redisson/src/main/java/org/redisson/connection/pool/ConnectionPool.java
+++ b/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);
         }
         
diff --git a/redisson/src/main/java/org/redisson/connection/pool/PubSubConnectionPool.java b/redisson/src/main/java/org/redisson/connection/pool/PubSubConnectionPool.java
index cf3900a7f..fc5776ca1 100644
--- a/redisson/src/main/java/org/redisson/connection/pool/PubSubConnectionPool.java
+++ b/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