diff --git a/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java b/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
index 649ccc750..980caca29 100644
--- a/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
+++ b/src/main/java/net/openhft/chronicle/map/AbstractChannelReplicator.java
@@ -233,10 +233,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)) {