0.1.14

leonchen83 · Jan 12, 2019 · 9236b90 · 9236b90
1 parent 316510b
commit 9236b90
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 13 deletions.
diff --git a/src/main/java/com/moilioncircle/redis/rdb/cli/ext/rmt/SingleRdbVisitor.java b/src/main/java/com/moilioncircle/redis/rdb/cli/ext/rmt/SingleRdbVisitor.java
@@ -113,7 +113,6 @@ public void retry(Event event, int times) {
         } catch (Throwable e) {
             times--;
             if (times >= 0 && flush) {
-                endpoint.get().flushQuietly();
                 endpoint.set(Endpoint.valueOf(endpoint.get()));
                 retry(event, times);
             }

diff --git a/src/main/java/com/moilioncircle/redis/rdb/cli/net/Endpoint.java b/src/main/java/com/moilioncircle/redis/rdb/cli/net/Endpoint.java
@@ -174,13 +174,6 @@ public void flush() {
         }
     }
 
-    public void flushQuietly() {
-        try {
-            flush();
-        } catch (Throwable e) {
-        }
-    }
-
     @Override
     public void close() throws IOException {
         Sockets.closeQuietly(in);
@@ -332,11 +325,8 @@ public RedisObject(Type type, Object object) {
         }
 
         public String getString() {
-            if (type.isString() || type.isError()) {
-                byte[] bytes = (byte[]) object;
-                return new String(bytes);
-            }
-            return null;
+            byte[] b = getBytes();
+            return b == null ? null : new String(b);
         }
 
         public byte[] getBytes() {