diff --git a/redisson/src/main/java/org/redisson/Redisson.java b/redisson/src/main/java/org/redisson/Redisson.java index 6f4077057..379f62cd1 100755 --- a/redisson/src/main/java/org/redisson/Redisson.java +++ b/redisson/src/main/java/org/redisson/Redisson.java @@ -654,12 +654,14 @@ public class Redisson implements RedissonClient { @Override public void shutdown() { + writeBehindService.stop(); connectionManager.shutdown(); } @Override public void shutdown(long quietPeriod, long timeout, TimeUnit unit) { + writeBehindService.stop(); connectionManager.shutdown(quietPeriod, timeout, unit); }