From c7ef524031ee4db66df4b243c704ded7b338328c Mon Sep 17 00:00:00 2001
From: Rob Austin <rob.austin@boundedbuffer.co.uk>
Date: Mon, 2 Feb 2015 10:01:13 +0000
Subject: [PATCH] ignore java.util.concurrent.RejectedExecutionException when
 already closed

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

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)) {