Fix bug in cluster psubscribe call

marcosnils · marcosnils · commit 8969566d0926 · 2016-04-18T13:19:05.000-03:00
Fixes #1258
diff --git a/src/main/java/redis/clients/jedis/BinaryJedisCluster.java b/src/main/java/redis/clients/jedis/BinaryJedisCluster.java
@@ -1598,7 +1598,7 @@ public void psubscribe(final BinaryJedisPubSub jedisPubSub, final byte[]... patt
     new JedisClusterCommand<Integer>(connectionHandler, maxRedirections) {
       @Override
       public Integer execute(Jedis connection) {
-        connection.subscribe(jedisPubSub, patterns);
+        connection.psubscribe(jedisPubSub, patterns);
         return 0;
       }
     }.runWithAnyNode();

Original file line number	Diff line number	Diff line change
`@@ -1598,7 +1598,7 @@ public void psubscribe(final BinaryJedisPubSub jedisPubSub, final byte[]... patt`
`1598`	`1598`	`new JedisClusterCommand<Integer>(connectionHandler, maxRedirections) {`
`1599`	`1599`	`@Override`
`1600`	`1600`	`public Integer execute(Jedis connection) {`
`1601`		`- connection.subscribe(jedisPubSub, patterns);`
	`1601`	`+ connection.psubscribe(jedisPubSub, patterns);`
`1602`	`1602`	`return 0;`
`1603`	`1603`	`}`
`1604`	`1604`	`}.runWithAnyNode();`