ignore java.util.concurrent.RejectedExecutionException when already closed

This commit is contained in:
Rob Austin
2015-07-25 16:04:14 +03:00
committed by leventov
parent 5606e7d264
commit c7ef524031
@@ -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)) {