in src/Libs/Common/Redis/MessageClient.cs [62:70]
public async Task WithHandlers(params MessageHandler[] handlers)
{
foreach (var handler in handlers ?? throw new ArgumentNullException(nameof(handlers)))
{
var cmq = await _subscriber.SubscribeAsync(
$"{TestId}:{handler.Role ?? _sender}:{handler.Command}:{handler.Type}");
cmq.OnMessage(cm => handler.Handle(cm.Message));
}
}