diff --git a/spring-integration-redis/src/main/java/org/springframework/integration/redis/util/RedisLockRegistry.java b/spring-integration-redis/src/main/java/org/springframework/integration/redis/util/RedisLockRegistry.java index 6baa12b6f6..8e0f3971c7 100644 --- a/spring-integration-redis/src/main/java/org/springframework/integration/redis/util/RedisLockRegistry.java +++ b/spring-integration-redis/src/main/java/org/springframework/integration/redis/util/RedisLockRegistry.java @@ -601,8 +601,9 @@ protected final boolean renew(long expireAfter) { } protected final void stopRenew() { - if (this.renewFuture != null) { - this.renewFuture.cancel(true); + ScheduledFuture renewFutureToCancel = this.renewFuture; + if (renewFutureToCancel != null) { + renewFutureToCancel.cancel(true); this.renewFuture = null; } }