From f31febcf3da29c5dc5db8699300e4621f8444a9c Mon Sep 17 00:00:00 2001 From: Nikita Date: Fri, 5 Aug 2016 12:11:56 +0300 Subject: [PATCH] change reverted --- .../org/redisson/connection/MasterSlaveConnectionManager.java | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java b/src/main/java/org/redisson/connection/MasterSlaveConnectionManager.java index 53c83dd8b..ad1284a1c 100644 --- 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 promise, final PubSubType type, final AsyncSemaphore lock) { - final int slot = calcSlot(channelName); + final int slot = 0; Future connFuture = nextPubSubConnection(slot); connFuture.addListener(new FutureListener() {