shutdown fixed

pull/5644/head
Nikita Koksharov 1 year ago
parent e7a4400a71
commit be5fde3ee9

@ -539,7 +539,9 @@ public class MasterSlaveConnectionManager implements ConnectionManager {
if (timeoutInNanos < quietPeriod) { if (timeoutInNanos < quietPeriod) {
quietPeriod = 0; quietPeriod = 0;
} }
serviceManager.getGroup().shutdownGracefully(unit.toNanos(quietPeriod), timeoutInNanos, TimeUnit.NANOSECONDS).syncUninterruptibly(); serviceManager.getGroup()
.shutdownGracefully(unit.toNanos(quietPeriod), timeoutInNanos, TimeUnit.NANOSECONDS)
.awaitUninterruptibly(timeoutInNanos, TimeUnit.NANOSECONDS);
} }
serviceManager.getTimer().stop(); serviceManager.getTimer().stop();

Loading…
Cancel
Save