在Microsoft.ServiceBus.Messaging.QueueClient（Reactive Extensions）上使用RX

Question

我有一個定價應用程序。它將定價請求發送到Azure服務總線隊列（可以是任何隊列）「PricingRequestQueue」。有許多工作人員選擇這些工作，處理它們並將結果返回給PricingResponse隊列。

我想通過PricingResponse隊列創建一個Observable。我不需要任何篩選，但希望使用批處理接口（QueueClient.BeginReceiveBatch）讀取消息。隊列中有預期的消息的數量，並具有從會話（QueueClient.AcceptMessageSession（correlationIdentifier）來讀取。

我仍然在試圖讓我的周圍RX頭，而這將是很清楚的事情了。

Answer 1

還有就是CloudFx庫，增加的Rx擴展到Azure上。

https://www.nuget.org/packages/Microsoft.Experience.CloudFx/（更新鏈接）

但是我必須警告你，我們發現在目前的CloudFx庫某個線程泄漏（尤其是表存儲一個 - 但是你不需要Rx擴展表存儲2.0）。