如何将标头附加到所有已发布的消息？

Question

我有一个特定的标题，我想将它附加到我发布的所有消息中。我可以通过在 Publish 调用中指定它来逐个附加此标头：

_bus.Publish(myMessage, context => context.SetHeader("my key", "my value"));

这很好用，但每次发布都维护这个SetHeader 调用变得很麻烦。在总线配置期间或其他任何地方，有没有办法指定将附加到所有消息的标头？也就是说，有没有办法执行以下操作？

ServiceBusFactory.New(sbc =>
{        
    sbc.UseRabbitMq();
    sbc.ReceiveFrom(hdoQueue);

    // This is what I'd like to be able to do:
    sbc.BeforePublish(context => context.SetHeader("my key", "my value"));
});

我相信有一个解决方案涉及实现IOutboundMessageInterceptor，但我找不到附加拦截器的方法。有ServiceBusConfigurator.AddInboundInterceptor 方法，但没有ServiceBusConfigurator.AddOutboundInterceptor 方法。

Answer 1

我的直觉是正确的，通过实现IOutboundMessageInterceptor，我能够做我想做的事：

public class AttachHeadersOutboundInterceptor : IOutboundMessageInterceptor
{
    public void PreDispatch(ISendContext context)
    {
        context.SetHeader("my key", "my value");
    }

    public void PostDispatch(ISendContext context)
    {
    }
}

奇怪的是没有ServiceBusConfigurator.AddOutboundInterceptor方法，所以我只创建了一个（通过从github复制the code for AddInboundInterceptor）：

public static class MassTransitExtensions
{
    public static void AddOutboundInterceptor(this ServiceBusConfigurator configurator,
        IOutboundMessageInterceptor interceptor)
    {
        var builderConfigurator = new PostCreateBusBuilderConfigurator(bus =>
        {
            var interceptorConfigurator = new OutboundMessageInterceptorConfigurator(bus.OutboundPipeline);

            interceptorConfigurator.Create(interceptor);
        });

        configurator.AddBusConfigurator(builderConfigurator);
    }
}

然后我在总线配置期间附加它：

ServiceBusFactory.New(sbc =>
{        
    sbc.UseRabbitMq();
    sbc.ReceiveFrom(hdoQueue);

    sbc.AddOutboundInterceptor(new AttachHeadersOutboundInterceptor());
});

问题解决了。