not cached connection errors (imperugo#296)

Co-authored-by: Anton Dimkov <anton.dimkov@ubisoft.com>
oTcom · Jul 12, 2020 · 3b96265 · 3b96265
1 parent 0d24a61
commit 3b96265
Showing 1 changed file with 5 additions and 2 deletions.
diff --git a/...re/StackExchange.Redis.Extensions.Core/Implementations/RedisCacheConnectionPoolManager.cs b/...re/StackExchange.Redis.Extensions.Core/Implementations/RedisCacheConnectionPoolManager.cs
@@ -1,6 +1,7 @@
 using System;
 using System.Collections.Concurrent;
 using System.Linq;
+using System.Threading;
 
 using Microsoft.Extensions.Logging;
 using Microsoft.Extensions.Logging.Abstractions;
@@ -101,7 +102,8 @@ public ConnectionPoolInformation GetConnectionInformations()
 
         private void EmitConnection()
         {
-            this.connections.Add(new Lazy<StateAwareConnection>(() =>
+            this.connections.Add(new Lazy<StateAwareConnection>(
+            () =>
             {
                 this.logger.LogDebug("Creating new Redis connection.");
 
@@ -114,7 +116,8 @@ private void EmitConnection()
                     multiplexer = multiplexer.GetSentinelMasterConnection(redisConfiguration.ConfigurationOptions);
 
                 return new StateAwareConnection(multiplexer, this.EmitConnection, logger);
-            }));
+            },
+            LazyThreadSafetyMode.PublicationOnly));
         }
 
         private void EmitConnections()