From efe6db066fa099774c01aeb425dc681c822b19d6 Mon Sep 17 00:00:00 2001
From: Rob Austin <rob.austin@boundedbuffer.co.uk>
Date: Tue, 15 Sep 2015 19:44:24 +0100
Subject: [PATCH] corrected    if (!attached.isServer ||
 !attached.isHandShakingComplete())                       return;

---
 src/main/java/net/openhft/chronicle/map/TcpReplicator.java | 3 ++-
 1 file changed, 2 insertions(+), 1 deletion(-)

diff --git a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
index 771527a57..f5dd29102 100644
--- a/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
+++ b/src/main/java/net/openhft/chronicle/map/TcpReplicator.java
@@ -388,7 +388,7 @@ public final class TcpReplicator<K, V> extends AbstractChannelReplicator impleme
 
         final Attached attached = (Attached) key.attachment();
 
-        if (attached.isServer && !attached.isHandShakingComplete())
+        if (!attached.isServer || !attached.isHandShakingComplete())
             return;
 
         final SocketChannel channel = (SocketChannel) key.channel();
@@ -412,6 +412,7 @@ public final class TcpReplicator<K, V> extends AbstractChannelReplicator impleme
             if (replicationConfig.autoReconnectedUponDroppedConnection())
                 attached.connector.connectLater();
         }
+
     }
 
     /**