RedisLockRegistry stopRenew not thread safe #10446

Closes #10446

Signed-off-by: PiotrDuz <[email protected]>

Signed-off-by: PiotrDuz <[email protected]>

Author: PiotrDuz

spring-integration-redis/src/main/java/org/springframework/integration/redis/util/RedisLockRegistry.java

@@ -598,9 +598,11 @@ protected final boolean renew(long expireAfter) {
 			return res;
 		}
 
+		/* This method can be called by more than 1 thread, thus we need to make sure that it is safe*/
 		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;
 			}
 		}