Estou usando o MassTransit 3.2.4 e estou tentando adicionar algumas informações de cabeçalho às minhas mensagens publicadas, mas o código para definir o cabeçalho nunca parece ser executado. Não sei por que isso não funciona.

var bus = Bus.Factory.CreateUsingRabbitMq(config =>
{
    var host = config.Host(new Uri("rabbitmq://localhost/"), h {});
    config.ReceiveEndpoint(host, "TestPublisher", e => 
    { 
        e.ConfigurePublish(x => x.UseSendExecute(context =>
            context.Headers.Set("HeaderKey", "HeaderValue")
        ));
    });
});

No lado do consumidor, estou tentando ler o cabeçalho

public Task Consume(ConsumeContext<IActionHappened> context)
{
    var headerValue = context.Headers.Get("HeaderKey", "Default Value");
}

Preciso adicionar um interceptador ou outra coisa para definir as informações do cabeçalho?