Fix ListAsync method of Redis store

asynkron · Aug 28, 2023 · 3d147cd · 3d147cd
1 parent 8d3670e
commit 3d147cd
Showing 1 changed file with 3 additions and 2 deletions.
diff --git a/src/Proto.Cluster.AzureContainerApps/Stores/Redis/RedisClusterMemberStore.cs b/src/Proto.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;
+    [CanBeNull] private IDatabase _database;
 
     /// <summary>
     /// Initializes a new instance of the <see cref="RedisClusterMemberStore"/> class.
@@ -33,7 +33,8 @@ public RedisClusterMemberStore(IRedisConnectionMultiplexerProvider connectionMul
     /// <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();
     }