如何创建具有作用域生存期的公共交通消息拦截器(观察器)

Question

我们可以使用以下方式设置Consume Observer

busControl.ConnectConsumeObserver(container.GetInstance<MessageConsumerInterceptor>());

我想将 Scope 生活方式应用于 MessageConsumerInterceptor，以便我可以在使用或处理消息之前填充/初始化某个对象。我可以通过消息处理程序或使用者访问该填充对象。现在我如何使用公共交通实现这一目标？

我期待您的帮助或可能的建议。

提前谢谢。

Answer 1

Observer 不是一个好的候选者。观察者只是观察，他们不应该改变任何状态或对消息处理产生影响。

您正在查看的是中间件。

查看此文档页面，了解如何创建和应用自定义中间件。

您将在筛选器中获取ConsumeContext作为Send方法参数，在那里您可以使用方法GetOrAddPayload<T>和TryGetPayload向上下文中添加一些内容，以便稍后可以在使用者中获取此数据。