From 6a7b1db319ac9e65b179481b2dfabb7f8a1420da Mon Sep 17 00:00:00 2001 From: Pat Shields Date: Mon, 30 Aug 2010 05:23:05 +0800 Subject: [PATCH] Need to get this reply from server, otherwise the next read is polluted --- src/main/java/redis/clients/jedis/Jedis.java | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/main/java/redis/clients/jedis/Jedis.java b/src/main/java/redis/clients/jedis/Jedis.java index d21ffaf..be7c7de 100644 --- a/src/main/java/redis/clients/jedis/Jedis.java +++ b/src/main/java/redis/clients/jedis/Jedis.java @@ -633,8 +633,9 @@ public class Jedis { client.rollbackTimeout(); } - public void publish(String channel, String message) { + public int publish(String channel, String message) { client.publish(channel, message); + return client.getIntegerReply(); } public void psubscribe(JedisPubSub jedisPubSub, String... patterns) {