Fixing issue with asynchronous handler

This might have been the underlying issue all along
TurnerSoftware · Nov 13, 2020 · 51d5424 · 51d5424
1 parent 3b40086
commit 51d5424
Showing 1 changed file with 13 additions and 12 deletions.
diff --git a/src/CacheTower.Extensions.Redis/RedisRemoteEvictionExtension.cs b/src/CacheTower.Extensions.Redis/RedisRemoteEvictionExtension.cs
@@ -52,20 +52,21 @@ public void Register(ICacheStack cacheStack)
 			}
 			IsRegistered = true;
 
-			Subscriber.Subscribe(RedisChannel, async (channel, value) =>
-			{
-				string cacheKey = value;
-				var shouldEvictLocally = false;
-				lock (FlaggedRefreshesLockObj)
+			Subscriber.Subscribe(RedisChannel, CommandFlags.FireAndForget)
+				.OnMessage(async (channelMessage) =>
 				{
-					shouldEvictLocally = FlaggedRefreshes.Remove(cacheKey) == false;
-				}
+					string cacheKey = channelMessage.Message;
+					var shouldEvictLocally = false;
+					lock (FlaggedRefreshesLockObj)
+					{
+						shouldEvictLocally = FlaggedRefreshes.Remove(cacheKey) == false;
+					}
 
-				if (shouldEvictLocally)
-				{
-					await cacheStack.EvictAsync(cacheKey);
-				}
-			}, CommandFlags.FireAndForget);
+					if (shouldEvictLocally)
+					{
+						await cacheStack.EvictAsync(cacheKey);
+					}
+				});
 		}
 	}
 }