Revert AbstractChannelReplicator logic change

This commit is contained in:
leventov
2015-07-01 16:31:36 +03:00
parent f0c9413a53
commit 3ae268e5e9
@@ -259,14 +259,7 @@ abstract class AbstractChannelReplicator implements Closeable {
executorService.shutdown();
try {
if (!executorService.awaitTermination(5, TimeUnit.MILLISECONDS)) {
executorService.shutdownNow();
try {
executorService.awaitTermination(10, TimeUnit.SECONDS);
} catch (InterruptedException e) {
LOG.error("", e);
}
}
executorService.awaitTermination(5, TimeUnit.MILLISECONDS);
} catch (Exception e) {
executorService.shutdownNow();
try {