ignore java.util.concurrent.RejectedExecutionException when already closed

This commit is contained in:
Rob Austin
2015-02-02 10:01:13 +00:00
parent 4726515284
commit 902cd25464
@@ -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)) {