Geek Answers Handbook

Use RX in Microsoft.ServiceBus.Messaging.QueueClient (reactive extensions)

I have a pricing app. It sends pricing requests to the Azure Service Bus (any queue) "PricingRequestQueue" queue. There are a number of employees who pick them up, process and return the results to the PricingResponse Queue.

I would like to create an Observable in the PricingResponse queue. I do not need filtering, but you want to read messages using the packet interface (QueueClient.BeginReceiveBatch). The queue has the expected number of messages and has a session to read (QueueClient.AcceptMessageSession (correIdentifier).

I'm still trying to bow my head to the RX, and that will really clarify the situation.

+4
source share
1 answer

There is a CloudFx library that adds Rx extensions to Azure.

https://www.nuget.org/packages/Microsoft.Experience.CloudFx/ (updated link)

However, I must warn you that we detected thread leaks in the current CloudFx libraries (in particular, using table storage, however, you do not need Rx extensions since the storage of tables 2.0).

+1
source

More articles:


All Articles