Allow to prepare the pool

src/main/java/org/springframework/data/redis/connection/lettuce/DefaultLettucePoolingClientConfiguration.java

@@ -38,12 +38,26 @@ class DefaultLettucePoolingClientConfiguration implements LettucePoolingClientCo
 
 	private final LettuceClientConfiguration clientConfiguration;
 	private final GenericObjectPoolConfig poolConfig;
+  private final boolean preparePool;
 
 	DefaultLettucePoolingClientConfiguration(LettuceClientConfiguration clientConfiguration,
 			GenericObjectPoolConfig poolConfig) {
 
 		this.clientConfiguration = clientConfiguration;
 		this.poolConfig = poolConfig;
+    this.preparePool = false;
+	}
+
+  DefaultLettucePoolingClientConfiguration(LettuceClientConfiguration clientConfiguration,
+                                           GenericObjectPoolConfig poolConfig, boolean preparePool) {
+    this.clientConfiguration = clientConfiguration;
+		this.poolConfig = poolConfig;
+    this.preparePool = preparePool;
+  }
+
+  @Override
+	public boolean preparePool() {
+		return preparePool;
 	}
 
 	@Override

src/main/java/org/springframework/data/redis/connection/lettuce/LettucePoolingClientConfiguration.java

@@ -36,6 +36,7 @@
  */
 public interface LettucePoolingClientConfiguration extends LettuceClientConfiguration {
 
+	boolean preparePool();
 	/**
 	 * @return the {@link GenericObjectPoolConfig}. Never {@literal null}.
 	 */
@@ -92,6 +93,7 @@ static LettucePoolingClientConfiguration defaultConfiguration() {
 	class LettucePoolingClientConfigurationBuilder extends LettuceClientConfigurationBuilder {
 
 		GenericObjectPoolConfig poolConfig = new GenericObjectPoolConfig();
+		boolean preparePool = false;
 
 		LettucePoolingClientConfigurationBuilder() {
 			super();
@@ -125,6 +127,12 @@ public LettucePoolingClientConfigurationBuilder commandTimeout(Duration timeout)
 			return this;
 		}
 
+		public LettucePoolingClientConfigurationBuilder preparePool(boolean preparePool) {
+
+			this.preparePool = preparePool;
+			return this;
+    }
+
 		@Override
 		public LettucePoolingClientConfigurationBuilder shutdownTimeout(Duration shutdownTimeout) {
 
@@ -173,7 +181,7 @@ public LettucePoolingClientConfigurationBuilder poolConfig(GenericObjectPoolConf
 
 		@Override
 		public LettucePoolingClientConfiguration build() {
-			return new DefaultLettucePoolingClientConfiguration(super.build(), poolConfig);
+			return new DefaultLettucePoolingClientConfiguration(super.build(), poolConfig, preparePool);
 		}
 	}
 

src/main/java/org/springframework/data/redis/connection/lettuce/LettucePoolingConnectionProvider.java

@@ -63,6 +63,7 @@ class LettucePoolingConnectionProvider implements LettuceConnectionProvider, Red
 	private static final Log log = LogFactory.getLog(LettucePoolingConnectionProvider.class);
 
 	private final LettuceConnectionProvider connectionProvider;
+  private final LettucePoolingClientConfiguration clientConfiguration;
 	private final GenericObjectPoolConfig poolConfig;
 	private final Map<StatefulConnection<?, ?>, GenericObjectPool<StatefulConnection<?, ?>>> poolRef = new ConcurrentHashMap<>(
 			32);
@@ -81,6 +82,7 @@ class LettucePoolingConnectionProvider implements LettuceConnectionProvider, Red
 		Assert.notNull(connectionProvider, "ConnectionProvider must not be null");
 		Assert.notNull(clientConfiguration, "ClientConfiguration must not be null");
 
+		this.clientConfiguration = clientConfiguration;
 		this.connectionProvider = connectionProvider;
 		this.poolConfig = clientConfiguration.getPoolConfig();
 		this.asyncPoolConfig = CommonsPool2ConfigConverter.bounded(this.poolConfig);
@@ -93,6 +95,14 @@ class LettucePoolingConnectionProvider implements LettuceConnectionProvider, Red
 			return ConnectionPoolSupport.createGenericObjectPool(() -> connectionProvider.getConnection(connectionType),
 					poolConfig, false);
 		});
+		if (clientConfiguration.preparePool()) {
+			try {
+				pool.preparePool();
+
+			} catch (Exception ex) {
+				throw new PoolException("Could not prepare the pool", ex);
+			}
+    }
 
 		try {