SemianiakaVY/elsa-core
1
0
Fork 0
Code Issues Pull requests Actions 1 Packages Projects Releases Wiki Activity

Fix ListAsync of Redis cluster member store

Browse source
This commit is contained in:
Sipke Schoorstra 2023-08-28 23:42:33 +02:00
parent b3e0c0064c
commit f0158245db
1 changed files with 3 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

5
src/modules/Elsa.ProtoActor.Cluster.AzureContainerApps/Stores/Redis/RedisClusterMemberStore.cs
View file

@ -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();
}