cs

public sealed class MessageErrorsManager
{
    readonly ConcurrentDictionary<string, MessageErrorObject> errors = new();
    public void AddError(MessageErrorObject? error)
    {
        var correlationId = CorrelationIdHelper.Get();
        try
        {
            Log.WriteDebug($"{nameof(MessageErrorsManager)}: started.", correlationId);
            if(error is null)
            {
                Log.WriteDebug($"Error is null.", correlationId);
                return;
            }
            if(errors.ContainsKey(error.Error))
            {
                Log.WriteDebug($"Increment error: {error}.", correlationId);
                errors[error.Error].Count++;
                return;
            }
            errors[error.Error] = error;
            Log.WriteWarning($"Was error: {error}.", correlationId);
        }
        catch(Exception ex)
        {
            Log.WriteException(ex, correlationId);
        }
        finally
        {
            Log.WriteDebug($"{nameof(MessageErrorsManager)}: ended.", correlationId);
        }
    }
    public void ClearErrors()
    {
        Log.WriteDebug($"{nameof(MessageErrorsManager)}: clear errors, errors count - {errors.Count}.", null);
        errors.Clear();
    }
    public IEnumerable<string> GetCriticalHealtnessErrors()
    {
        IEnumerable<string> result = Array.Empty<string>();
        try
        {
            result = errors.Values.Where(e => e.HasCriticalHealthinessErrors).Select(e => e.Error);
            return result;
        }
        catch(Exception ex)
        {
            Log.WriteException(ex, null);
            return result;
        }
        finally
        {
            Log.WriteError($"{nameof(GetCriticalHealtnessErrors)}: return value - {result.ToJson()}.", null);
        }
    }
    public bool HasCriticalHealtnessErrors() => GetCriticalHealtnessErrors().Any();
}