c# – 在Microsoft.ServiceBus.Messaging.QueueClient上使用RX(R

发布时间：2020-12-15 22:01:55 所属栏目：百科来源：网络整理

导读：我有定价申请.它将定价请求发送到Azure服务总线队列(可以是任何队列)“PricingRequestQueue”.有许多工作人员选择这些工作,处理它们并将结果返回到PricingResponse队列. 我想在PricingResponse队列上创建一个Observable.我不需要任何过滤,但想使用批处理接口

我有定价申请.它将定价请求发送到Azure服务总线队列(可以是任何队列)“PricingRequestQueue”.有许多工作人员选择这些工作,处理它们并将结果返回到PricingResponse队列.

我想在PricingResponse队列上创建一个Observable.我不需要任何过滤,但想使用批处理接口(QueueClient.BeginReceiveBatch)读取消息.队列具有预期的消息数,并具有要读取的会话(QueueClient.AcceptMessageSession(correlationIdentifier)).

我仍然试图绕过RX,这真的很清楚.

解决方法

有一个CloudFx库可以向Azure添加Rx扩展.

https://www.nuget.org/packages/Microsoft.Experience.CloudFx/(更新链接)

但是我必须警告你,我们在当前的CloudFx库中发现了一些线程泄漏(特别是对于表存储库 – 但是你不需要自表存储2.0以来的Rx扩展).

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!