1

我想围绕 Polly 框架创建一个通用包装器,以便可以有单个实现。为了实现它,我写了下面的代码

    private Policy GetPolicy(EType eType)
    {
        var policy = default(Polly.Policy);

        switch (eType)
        {                

            case EType.T:
                policy = Policy.Handle<SomeException>().Retry(n, x => new TimeSpan(0, 0, x));
                break;                
        }
        return policy;
    }  

我在我的一种包装方法中使用上述方法

   public TOutput Execute<TOutput>(Func<TOutput> func, EType eType)
    {
        var policy = GetPolicy(eType);

        return policy.Execute(() => func());
    }

现在为了使用它,我编写了一个示例方法

       var handleError = new HandleError();
        var connection = handleError.Execute(() => factory.CreateConnection(), ExceptionType.Transient);

直到最重要的是工作正常,但是一旦我开始在一个接受参数的方法中调用它,它就会抛出错误

     var handleError = new HandleError();
        handleError.Execute(() => channel.ExchangeDeclare(queueDetail.ExchangeName, ExchangeType.Fanout), ExceptionType.Transient);

     The type arguments for method 'HandleError.Execute<TOutput>(Func<TOutput>, ExceptionType)' cannot be inferred from the usage. Try specifying the type arguments explicitly.
4

1 回答 1

2

您需要两个Execute重载,一个用于返回值的函数,另一个用于不返回值的函数:

public TOutput Execute<TOutput>(Func<TOutput> func, ExceptionType exceptionType)
{
    var policy = GetPolicyFromExceptionType(exceptionType);
    return policy.Execute(func);
}

public void Execute(Action action, ExceptionType exceptionType)
{
    var policy = GetPolicyFromExceptionType(exceptionType);
    policy.Execute(action);
}

然后你可以在那里传递任何东西,包括带参数的函数:

// calls first overload
Execute(() => ImReturningValue(parameter1));
// calls second
Execute(() => IDoNot(parameter1));

Policy.Execute方法也具有相同的重载(一个用于 Func,一个用于 Action) - 因此将任何一个传递给它都没有问题。

于 2017-12-07T14:13:29.320 回答