From 522f0503b3492b09578c7b289fe4a0a8f0dbcca2 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 119491828..f94f6a6a2 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 @@ final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Clo
 
         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 @@ final class TcpReplicator<K, V> extends AbstractChannelReplicator implements Clo
             if (replicationConfig.autoReconnectedUponDroppedConnection())
                 attached.connector.connectLater();
         }
+
     }
 
     /**