From f0158245dbd6359d5bd3791aeb6a5f1a8ff15394 Mon Sep 17 00:00:00 2001
From: Sipke Schoorstra <sipkeschoorstra@outlook.com>
Date: Mon, 28 Aug 2023 23:42:33 +0200
Subject: [PATCH] Fix ListAsync of Redis cluster member store

---
 .../Stores/Redis/RedisClusterMemberStore.cs                  | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git a/src/modules/Elsa.ProtoActor.Cluster.AzureContainerApps/Stores/Redis/RedisClusterMemberStore.cs b/src/modules/Elsa.ProtoActor.Cluster.AzureContainerApps/Stores/Redis/RedisClusterMemberStore.cs
index a6b432f5a..45ec67fa3 100644
--- a/src/modules/Elsa.ProtoActor.Cluster.AzureContainerApps/Stores/Redis/RedisClusterMemberStore.cs
+++ b/src/modules/Elsa.ProtoActor.Cluster.AzureContainerApps/Stores/Redis/RedisClusterMemberStore.cs
@@ -19,7 +19,7 @@ public class RedisClusterMemberStore : IClusterMemberStore
     private readonly IRedisConnectionMultiplexerProvider _connectionMultiplexerProvider;
     private readonly ISystemClock _systemClock;
     private const string ClusterKey = "proto:cluster:members";
-    private IDatabase _database;
+    private IDatabase? _database;
 
     /// <summary>
     /// Initializes a new instance of the <see cref="RedisClusterMemberStore"/> class.
@@ -33,7 +33,8 @@ public class RedisClusterMemberStore : IClusterMemberStore
     /// <inheritdoc />
     public async ValueTask<ICollection<StoredMember>> ListAsync(CancellationToken cancellationToken = default)
     {
-        var entries = await _database.HashGetAllAsync(ClusterKey);
+        var database = await GetDatabaseAsync();
+        var entries = await database.HashGetAllAsync(ClusterKey);
         return entries.Select(entry => Deserialize(entry.Value!)).ToList();
     }