Polishing.

Move maxTime calculation for topology refresh to and delegate shouldUseCachedValue() to newly introduced overload.
Retain application flow as much as possible.

Original Pull Request: #2989

Author: christophstrobl

src/main/java/org/springframework/data/redis/connection/jedis/JedisClusterConnection.java

@@ -841,7 +841,7 @@ public JedisClusterTopologyProvider(JedisCluster cluster, Duration cacheTimeout)
 		public ClusterTopology getTopology() {
 
 			JedisClusterTopology topology = cached;
-			if (shouldUseCachedValue(topology)) {
+			if (shouldUseCachedValue()) { // retain method call behaviour
 				return topology;
 			}
 
@@ -854,9 +854,8 @@ public ClusterTopology getTopology() {
 
 				try (Connection connection = entry.getValue().getResource()) {
 
-
 					Set<RedisClusterNode> nodes = Converters.toSetOfRedisClusterNodes(new Jedis(connection).clusterNodes());
-					topology = cached = new JedisClusterTopology(nodes, System.currentTimeMillis());
+					topology = cached = new JedisClusterTopology(nodes, System.currentTimeMillis(), cacheTimeMs);
 					return topology;
 
 				} catch (Exception ex) {
@@ -884,9 +883,9 @@ public ClusterTopology getTopology() {
 		 * @since 2.2
 		 * @deprecated since 3.3.4, use {@link #shouldUseCachedValue(JedisClusterTopology)} instead.
 		 */
-		@Deprecated(since = "3.3.4")
+		@Deprecated(since = "3.3.4", forRemoval = true)
 		protected boolean shouldUseCachedValue() {
-			return false;
+			return shouldUseCachedValue(cached);
 		}
 
 		/**
@@ -899,22 +898,38 @@ protected boolean shouldUseCachedValue() {
 		 * @since 3.3.4
 		 */
 		protected boolean shouldUseCachedValue(@Nullable JedisClusterTopology topology) {
-			return topology != null && topology.getTime() + cacheTimeMs > System.currentTimeMillis();
+			return topology != null && topology.getMaxTime() > System.currentTimeMillis();
 		}
 	}
 
 	protected static class JedisClusterTopology extends ClusterTopology {
 
 		private final long time;
+		private final long timeoutMs;
 
-		public JedisClusterTopology(Set<RedisClusterNode> nodes, long time) {
+		JedisClusterTopology(Set<RedisClusterNode> nodes, long creationTimeMs, long timeoutMs) {
 			super(nodes);
-			this.time = time;
+			this.time = creationTimeMs;
+			this.timeoutMs = timeoutMs;
 		}
 
+		/**
+		 * Get the time in ms when the {@link ClusterTopology} was captured.
+		 *
+		 * @return ClusterTopology time.
+		 */
 		public long getTime() {
 			return time;
 		}
+
+		/**
+		 * Get the maximum time in ms the {@link ClusterTopology} should be used before a refresh is required.
+		 *
+		 * @return ClusterTopology maximum age.
+		 */
+		long getMaxTime() {
+			return time + timeoutMs;
+		}
 	}
 
 	protected JedisCluster getCluster() {

src/test/java/org/springframework/data/redis/connection/jedis/JedisClusterConnectionTests.java

@@ -2965,8 +2965,8 @@ void shouldUseCachedTopology() {
 		assertThat(topology).isInstanceOf(JedisClusterConnection.JedisClusterTopology.class);
 
 		assertThat(provider.shouldUseCachedValue(null)).isFalse();
-		assertThat(provider.shouldUseCachedValue(new JedisClusterConnection.JedisClusterTopology(Set.of(), 0))).isFalse();
+		assertThat(provider.shouldUseCachedValue(new JedisClusterConnection.JedisClusterTopology(Set.of(), System.currentTimeMillis() - 101, 100))).isFalse();
 		assertThat(provider.shouldUseCachedValue(
-				new JedisClusterConnection.JedisClusterTopology(Set.of(), System.currentTimeMillis() + 100))).isTrue();
+				new JedisClusterConnection.JedisClusterTopology(Set.of(), System.currentTimeMillis() + 100, 100))).isTrue();
 	}
 }