@@ -60,12 +60,15 @@ public final class CacheModule {
6060 public static Optional <UnifiedJedis > provideJedis (
6161 @ ApplicationDefaultCredential GoogleCredentialsBundle credentialsBundle ,
6262 @ Config ("valkeyHostsAndPorts" ) Optional <ImmutableList <String >> valkeyHostsAndPorts ,
63- @ Config ("valkeySslSocketFactory" ) SSLSocketFactory valkeySslSocketFactory ) {
64- if (valkeyHostsAndPorts .map (ImmutableList ::isEmpty ).orElse (true )) {
63+ @ Config ("valkeyCertificateAuthority" ) Optional <String > valkeyCertificateAuthority ) {
64+ if (valkeyHostsAndPorts .map (ImmutableList ::isEmpty ).orElse (true )
65+ || valkeyCertificateAuthority .isEmpty ()) {
6566 return Optional .empty ();
6667 }
6768 ImmutableSet <HostAndPort > hostsAndPorts =
6869 valkeyHostsAndPorts .get ().stream ().map (HostAndPort ::from ).collect (toImmutableSet ());
70+ SSLSocketFactory valkeySslSocketFactory =
71+ createValkeySslSocketFactory (valkeyCertificateAuthority .get ());
6972 JedisClientConfig clientConfig =
7073 DefaultJedisClientConfig .builder ()
7174 .ssl (true )
@@ -111,11 +114,7 @@ public static HostCache provideHostCache(
111114 return new MultilayerHostCache (jedisClient .get (), cacheMetrics );
112115 }
113116
114- @ Provides
115- @ Singleton
116- @ Config ("valkeySslSocketFactory" )
117- static SSLSocketFactory provideValkeySslSocketFactory (
118- @ Config ("valkeyCertificateAuthority" ) String valkeyCertificateAuthority ) {
117+ private static SSLSocketFactory createValkeySslSocketFactory (String valkeyCertificateAuthority ) {
119118 try {
120119 ImmutableList <X509Certificate > trustedCerts =
121120 CertificateFactory .getInstance ("X.509" )
0 commit comments