in src/Libs/Common/Redis/MessageClient.cs [46:60]
public async static Task<MessageClient> ConnectAsync(string connectionString, string testId, string sender)
{
if (string.IsNullOrEmpty(testId))
{
throw new ArgumentException("Test id cannot be empty.", nameof(testId));
}
var connection =
await ConnectionMultiplexer.ConnectAsync(connectionString ??
throw new ArgumentNullException(nameof(connectionString)));
var subscriber = connection.GetSubscriber();
var database = connection.GetDatabase();
var result = new MessageClient(connection, subscriber, database, testId, sender);
return result;
}