我试图将标题添加到Masstransit消息中,该消息包含来自WCF Web应用程序上当前登录的用户的信息.
I am trying to add a header to a Masstransit message containing information from the currently logged user on a WCF Web application.
因此在我的Web应用程序中,当应用程序启动时,我有以下内容:
So at my web app, I have the following when the app starts:
IBusControl bus = Bus.Factory.CreateUsingRabbitMq(cfg => { cfg.Host(new Uri("rabbitmq://localhost/test"), r => { //... }); cfg.ConfigureSend( s => s.UseSendExecute( c => c.Headers.Set(Constants.UserInfo, OperationContext.Current.Channel.Extensions.Find<PropertyUserInfo>().Info))); });
我使用IoC容器在应用程序(单一作用域)中仅创建一次IBusControl,然后将IBusControl注入到Web服务中.
I am using an IoC container to create IBusControl only once in the application (singleton scope), then IBusControl gets injected into the Web service.
请注意,当我创建服务总线时,OperationContext.Current不存在,我希望在请求上下文中调用lambda c= > c.Headers.Set(...)
Note that OperationContext.Current does not exists when I am creating the servicebus, I am expecting the lambda c= > c.Headers.Set(...) to be called within the request context
现在,当用户发出请求时,我正在使用请求-响应模式(尽管我认为这并不重要)
Now, when the user makes a request, I am using a request-response pattern (although I dont think this matters)
var requestClient = _bus.CreateRequestClient<AddTicketRequest, AddTicketResponse>(uri, timeout); var response = requestClient.Request(requestMessage);问题是,当执行此代码时,Masstransit尝试将标头添加到消息中,OperationContext.Current是null,因为它显然在与用户调用不同的线程上运行.
The problem is, when this code is executed, and Masstransit tries to add the header to the message, OperationContext.Current is null as apparently it is running on a different thread then the user call.
奇怪的是,最终Masstransit开始从正确的线程调用UseSendExecute,一切开始正常工作.而且我必须重新启动IIS才能再次复制该错误(!?).
Oddly enough, eventually Masstransit starts to call UseSendExecute from the right thread, and everything starts to work. And I have to restart IIS to replicate the bug again (!?).
有人遇到过这个问题吗?谢谢.
Has anybody ever had this problem ? thanks.
我知道我可以在发布消息时添加标头,但是我希望所有来自Web应用程序的消息都具有此标头,并且希望在全局范围内进行设置.
推荐答案问题 github/MassTransit/MassTransit/issues/921 看起来很相关.我将采用相同的解决方法,并将使用IBusControl的包装器.
The issue github/MassTransit/MassTransit/issues/921 looks related. I'll go with the same workaround, and I will work with a wrapper around IBusControl.
更多推荐
无法从OperationContext向MassTransit消息添加标头吗?
发布评论