MassTransit: Hinzufügen von Headern zum Veröffentlichen der Pipeline
Ich verwende MassTransit 3.2.4 und versuche, meinen veröffentlichten Nachrichten einige Headerinformationen hinzuzufügen, aber der Code zum Festlegen des Headers scheint nie zu funktionieren. 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")
));
});
});
uf der Verbraucherseite versuche ich den Header zu lesen
public Task Consume(ConsumeContext<IActionHappened> context)
{
var headerValue = context.Headers.Get("HeaderKey", "Default Value");
}
Muss ich einen Interceptor oder etwas anderes hinzufügen, um die Header-Informationen festzulegen?