|
|
|
@ -91,7 +91,8 @@ class LettuceConnectionConfiguration extends RedisConnectionConfiguration { |
|
|
|
ObjectProvider<LettuceClientConfigurationBuilderCustomizer> clientConfigurationBuilderCustomizers, |
|
|
|
ObjectProvider<LettuceClientConfigurationBuilderCustomizer> clientConfigurationBuilderCustomizers, |
|
|
|
ObjectProvider<LettuceClientOptionsBuilderCustomizer> clientOptionsBuilderCustomizers, |
|
|
|
ObjectProvider<LettuceClientOptionsBuilderCustomizer> clientOptionsBuilderCustomizers, |
|
|
|
ClientResources clientResources) { |
|
|
|
ClientResources clientResources) { |
|
|
|
return createConnectionFactory(clientConfigurationBuilderCustomizers, clientOptionsBuilderCustomizers, clientResources); |
|
|
|
return createConnectionFactory(clientConfigurationBuilderCustomizers, clientOptionsBuilderCustomizers, |
|
|
|
|
|
|
|
clientResources); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@Bean |
|
|
|
@Bean |
|
|
|
@ -101,7 +102,8 @@ class LettuceConnectionConfiguration extends RedisConnectionConfiguration { |
|
|
|
ObjectProvider<LettuceClientConfigurationBuilderCustomizer> clientConfigurationBuilderCustomizers, |
|
|
|
ObjectProvider<LettuceClientConfigurationBuilderCustomizer> clientConfigurationBuilderCustomizers, |
|
|
|
ObjectProvider<LettuceClientOptionsBuilderCustomizer> clientOptionsBuilderCustomizers, |
|
|
|
ObjectProvider<LettuceClientOptionsBuilderCustomizer> clientOptionsBuilderCustomizers, |
|
|
|
ClientResources clientResources) { |
|
|
|
ClientResources clientResources) { |
|
|
|
LettuceConnectionFactory factory = createConnectionFactory(clientConfigurationBuilderCustomizers, clientOptionsBuilderCustomizers, clientResources); |
|
|
|
LettuceConnectionFactory factory = createConnectionFactory(clientConfigurationBuilderCustomizers, |
|
|
|
|
|
|
|
clientOptionsBuilderCustomizers, clientResources); |
|
|
|
SimpleAsyncTaskExecutor executor = new SimpleAsyncTaskExecutor("redis-"); |
|
|
|
SimpleAsyncTaskExecutor executor = new SimpleAsyncTaskExecutor("redis-"); |
|
|
|
executor.setVirtualThreads(true); |
|
|
|
executor.setVirtualThreads(true); |
|
|
|
factory.setExecutor(executor); |
|
|
|
factory.setExecutor(executor); |
|
|
|
@ -112,8 +114,8 @@ class LettuceConnectionConfiguration extends RedisConnectionConfiguration { |
|
|
|
ObjectProvider<LettuceClientConfigurationBuilderCustomizer> clientConfigurationBuilderCustomizers, |
|
|
|
ObjectProvider<LettuceClientConfigurationBuilderCustomizer> clientConfigurationBuilderCustomizers, |
|
|
|
ObjectProvider<LettuceClientOptionsBuilderCustomizer> clientOptionsBuilderCustomizers, |
|
|
|
ObjectProvider<LettuceClientOptionsBuilderCustomizer> clientOptionsBuilderCustomizers, |
|
|
|
ClientResources clientResources) { |
|
|
|
ClientResources clientResources) { |
|
|
|
LettuceClientConfiguration clientConfig = getLettuceClientConfiguration(clientConfigurationBuilderCustomizers, clientOptionsBuilderCustomizers, |
|
|
|
LettuceClientConfiguration clientConfig = getLettuceClientConfiguration(clientConfigurationBuilderCustomizers, |
|
|
|
clientResources, getProperties().getLettuce().getPool()); |
|
|
|
clientOptionsBuilderCustomizers, clientResources, getProperties().getLettuce().getPool()); |
|
|
|
return createLettuceConnectionFactory(clientConfig); |
|
|
|
return createLettuceConnectionFactory(clientConfig); |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
@ -167,7 +169,8 @@ class LettuceConnectionConfiguration extends RedisConnectionConfiguration { |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
private ClientOptions createClientOptions(ObjectProvider<LettuceClientOptionsBuilderCustomizer> clientConfigurationBuilderCustomizers) { |
|
|
|
private ClientOptions createClientOptions( |
|
|
|
|
|
|
|
ObjectProvider<LettuceClientOptionsBuilderCustomizer> clientConfigurationBuilderCustomizers) { |
|
|
|
ClientOptions.Builder builder = initializeClientOptionsBuilder(); |
|
|
|
ClientOptions.Builder builder = initializeClientOptionsBuilder(); |
|
|
|
Duration connectTimeout = getProperties().getConnectTimeout(); |
|
|
|
Duration connectTimeout = getProperties().getConnectTimeout(); |
|
|
|
if (connectTimeout != null) { |
|
|
|
if (connectTimeout != null) { |
|
|
|
|