MassTransit: Hinzufügen von Überschriften zu veröffentlichen Pipeline

Question

Ich benutze MassTransit 3.2.4 und ich versuche, einige Headerinformationen für meine veröffentlichten Nachrichten hinzuzufügen, aber der Code zum Setzen der Kopfzeile scheint nie zu laufen. Ich bin mir nicht sicher, warum das nicht funktioniert.

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

Auf dem Verbraucher Ende ich den Header zu lesen bin versucht

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

Muß ich sonst einen Abfangjäger oder etwas hinzufügen, um Header-Informationen einstellen?

Answer 1

Nach viel Raten erraten. Just hatte ConfigurePublish an der falschen Stelle

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