change reverted

9 years ago · f31febcf3d
parent 7651ceedb1
commit f31febcf3d
1 changed files with 1 additions and 1 deletions
--- a/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java
+++ b/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java
@ -421,7 +421,7 @@ public class MasterSlaveConnectionManager implements ConnectionManager {

    private void connect(final Codec codec, final String channelName, final RedisPubSubListener<?> listener,
            final Promise<PubSubConnectionEntry> promise, final PubSubType type, final AsyncSemaphore lock) {
-        final int slot = calcSlot(channelName);
+        final int slot = 0;
        Future<RedisPubSubConnection> connFuture = nextPubSubConnection(slot);
        connFuture.addListener(new FutureListener<RedisPubSubConnection>() {