Я использую MassTransit 3.2.4 и пытаюсь добавить некоторую информацию заголовка в мои опубликованные сообщения, но код для установки заголовка, кажется, никогда не запускается. Я не уверен, почему это не работает.

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")
        ));
    });
});

На потребительском конце я пытаюсь прочитать заголовок

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

Нужно ли добавить перехватчик или что-то еще для того, чтобы установить информацию заголовка?