分类导航

程序问答发布时间：2022-06-02 发布网站：大佬教程 code.js-code.com

大佬教程收集整理的这篇文章主要介绍了MassTransit - 无法覆盖 RoutingSlipResponseProxy，大佬教程大佬觉得挺不错的，现在分享给大家，也给大家做个参考。

如何解决MassTransit - 无法覆盖 RoutIngSlipResponseProxy？

开发过程中遇到MassTransit - 无法覆盖 RoutIngSlipResponseProxy的问题如何解决？下面主要结合日常开发的经验，给出你关于MassTransit - 无法覆盖 RoutIngSlipResponseProxy的解决方法建议，希望对你解决MassTransit - 无法覆盖 RoutIngSlipResponseProxy有所启发或帮助；

我正在尝试设置一个 RoutIngSlipResponseProxy，如果没有 requestID，它将阻止发送响应。我试图通过覆盖我的 Consume 中的 RoutIngSlipResponseProxy 方法来做到这一点，如下所示：@H_675_11@

public class MigrateResponseProxy : RoutIngSlipResponseProxy<IMigrationrequested,IMigrationComplete>
{
    public new async Task Consume(ConsumeContext<RoutIngSlipCompleted> context)
    {
        var isrequest = context.@R_616_8798@ge.Variables.ContainsKey("requestID");
        if (!isrequest)
            return;

        var request = context.@R_616_8798@ge.Getvariable<IMigrationrequested>("request");
        var requestID = context.@R_616_8798@ge.Getvariable<GuID>("requestID");

        Uri responseAddress = null;
        if (context.@R_616_8798@ge.Variables.ContainsKey("ResponseAddress"))
            responseAddress = context.@R_616_8798@ge.Getvariable<Uri>("ResponseAddress");

        if (responseAddress == null)
            throw new Argumentexception($"The response address Could not be found for the faulted routIng slip: {Context.@R_616_8798@ge.Trackingnumber}");

        var endpoint = await context.GetResponseEndpoint<IMigrationComplete>(responseAddress,requestID).ConfigureAwait(false);

        var response = await CreateResponse@R_616_8798@ge(context,request);

        await endpoint.Send(responsE).ConfigureAwait(false);
    }

    ... remaining code ...
}