1.0.15-release

fix socket close bug
leonchen83 · Nov 22, 2016 · 3f24013 · 3f24013
1 parent a0cea68
commit 3f24013
Showing 1 changed file with 2 additions and 1 deletion.
diff --git a/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java b/src/main/java/com/moilioncircle/redis/replicator/RedisSocketReplicator.java
@@ -90,7 +90,8 @@ public void open() throws IOException {
                 final String reply = (String) reply();
 
                 SyncMode syncMode = trySync(reply);
-                if (syncMode == SyncMode.PSYNC) {
+                //bug fix.
+                if (syncMode == SyncMode.PSYNC && connected.get()) {
                     //heart beat send REPLCONF ACK ${slave offset}
 
                     heartBeat = new Timer("heart beat");