diff --git a/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/Connection.java b/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/Connection.java
index fef773ccc..36a0b3198 100644
--- a/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/Connection.java
+++ b/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/Connection.java
@@ -276,6 +276,11 @@ public class Connection implements Closeable {
     return (List<Object>) readProtocolWithCheckingBroken();
   }
 
+  @SuppressWarnings("unchecked")
+  public List<Object> getUnflushedObjectMultiBulkReply() {
+    return (List<Object>) readProtocolWithCheckingBroken();
+  }
+
   public List<Object> getObjectMultiBulkReply() {
     return getRawObjectMultiBulkReply();
   }
diff --git a/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisPubSub.java b/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisPubSub.java
index ef2973500..dd23d2f69 100644
--- a/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisPubSub.java
+++ b/fine-jedis/src/main/java/com/fr/third/redis/clients/jedis/JedisPubSub.java
@@ -128,7 +128,7 @@ public abstract class JedisPubSub {
   private void process(Client client) {
 
     do {
-      List<Object> reply = client.getRawObjectMultiBulkReply();
+      List<Object> reply = client.getUnflushedObjectMultiBulkReply();
       final Object firstObj = reply.get(0);
       if (!(firstObj instanceof byte[])) {
         throw new JedisException("Unknown message type: " + firstObj);