MassTransit

Question

我正在尝试设置一个 RoutingSlipResponseProxy，如果没有 RequestId，它将阻止发送响应。我试图通过重写 RoutingSlipResponseProxy 中的 Consume 方法来做到这一点，就像这样：

public class MigrateResponseProxy : RoutingSlipResponseProxy<IMigrationRequested, IMigrationComplete>
{
    public new async Task Consume(ConsumeContext<RoutingSlipCompleted> context)
    {
        var isRequest = context.Message.Variables.ContainsKey("RequestId");
        if (!isRequest)
            return;

        var request = context.Message.GetVariable<IMigrationRequested>("Request");
        var requestId = context.Message.GetVariable<Guid>("RequestId");

        Uri responseAddress = null;
        if (context.Message.Variables.ContainsKey("ResponseAddress"))
            responseAddress = context.Message.GetVariable<Uri>("ResponseAddress");

        if (responseAddress == null)
            throw new ArgumentException($"The response address could not be found for the faulted routing slip: {context.Message.TrackingNumber}");

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

        var response = await CreateResponseMessage(context, request);

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

    ... remaining code ...
}

这与 original method 的代码基本相同，只是在开头检查了 RequestId。但是，在通过代码进行调试时，似乎永远不会调用这个重写的方法，而是调用父方法。有什么我可能在这里遗漏的吗？任何帮助将不胜感激。

Answer 1

这些方法不是虚拟的，因此您将无法覆盖它们。在这种情况下，您最好将代理代码复制到您自己的项目中，而不是使用 MassTransit 中包含的实现。

You're welcome to submit a PR to make those methods virtual.

MassTransit - 无法覆盖 RoutingSlipResponseProxy 的 Consume 方法

MassTransit - Cannot override the Consume method from RoutingSlipResponseProxy

c#