我有一个定价应用程序。它将定价请求发送到 Azure 服务总线队列(可以是任何队列)“PricingRequestQueue”。有许多工作人员拾取这些数据，对其进行处理并将结果返回到 PricingResponse 队列。
我想在 PricingResponse 队列上创建一个 Observable。我不需要任何过滤，但想使用批处理接口(interface)(QueueClient.BeginReceiveBatch)读取消息。队列具有预期的消息数量，并且有一个可从中读取的 session (QueueClient.AcceptMessageSession(correlationIdentifier)。
我仍在努力了解 RX，这确实能让事情变得清晰。
最佳答案
CloudFx 库将 Rx 扩展添加到 Azure。
https://www.nuget.org/packages/Microsoft.Experience.CloudFx/ (更新链接)
但是我必须警告您，我们在当前的 CloudFx 库中发现了一些线程泄漏(特别是表存储库 - 但是自表存储 2.0 以来您不再需要 Rx 扩展)。
关于c# - 在 Microsoft.ServiceBus.Messaging.QueueClient(响应式(Reactive)扩展)上使用 RX，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/21969216/