Mass transit: agregar encabezados para publicar canalizaciones
Estoy usando Mass transit 3.2.4 y estoy tratando de agregar alguna información de encabezado a mis mensajes publicados, pero el código para configurar el encabezado nunca parece ejecutarse. No estoy seguro de por qué esto no 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")
));
});
});
En el lado del consumidor, estoy tratando de leer el encabezado
public Task Consume(ConsumeContext<IActionHappened> context)
{
var headerValue = context.Headers.Get("HeaderKey", "Default Value");
}
¿Necesito agregar un interceptor u otra cosa para configurar la información del encabezado?