remove retires

leonchen83 · Aug 23, 2016 · ca0e62f · ca0e62f
1 parent d423b0c
commit ca0e62f
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 5 deletions.
diff --git a/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java b/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java
@@ -278,7 +278,7 @@ private void connect() throws IOException {
         }
         socket.connect(new InetSocketAddress(host, port), configuration.getConnectionTimeout());
         outputStream = new RedisOutputStream(socket.getOutputStream());
-        inputStream = new RedisInputStream(socket.getInputStream(), configuration.getBufferSize(), configuration.getRetries());
+        inputStream = new RedisInputStream(socket.getInputStream(), configuration.getBufferSize());
         replyParser = new ReplyParser(inputStream);
     }
 

diff --git a/src/main/java/com/moilioncircle/redis/replicator/io/RedisInputStream.java b/src/main/java/com/moilioncircle/redis/replicator/io/RedisInputStream.java
@@ -26,7 +26,6 @@
 public class RedisInputStream extends InputStream {
 
     private final InputStream in;
-    private final int retries;
 
     private long total = 0;
     private int head = 0;
@@ -37,13 +36,12 @@ public class RedisInputStream extends InputStream {
     private final byte[] buf;
 
     public RedisInputStream(final InputStream in) {
-        this(in, 8192, 5);
+        this(in, 8192);
     }
 
-    public RedisInputStream(final InputStream in, int len, int retries) {
+    public RedisInputStream(final InputStream in, int len) {
         this.in = in;
         this.buf = new byte[len];
-        this.retries = retries;
     }
 
     public int head() {