diff --git a/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java b/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
index 5548c87af..7f34f1f1b 100644
--- a/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
+++ b/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
@@ -236,10 +236,11 @@ abstract class AbstractChannelReplicator implements Closeable {
 
     @Override
     public void close() {
+
         if (Thread.interrupted())
             LOG.warn("Already interrupted");
         long start = System.currentTimeMillis();
-
+        isClosed = true;
         connectExecutorService.shutdown();
         try {
             if (!connectExecutorService.awaitTermination(5, TimeUnit.MILLISECONDS)) {