Microsoft.ServiceBus.Messaging.QueueClient (Reactive Extensions)에서 RX 사용

Question

나는 가격 애플리케이션이 있습니다. Azure 서비스 버스 대기열 (모든 대기열 일 수 있음) "PricingRequestQueue"로 가격 요청을 보냅니다. 이를 선택하여 처리하고 결과를 PricingResponse Queue로 반환하는 많은 직원이 있습니다.

PricingResponse 큐를 통해 Observable을 만들고 싶습니다. 어떤 필터링도 필요하지 않지만 배치 인터페이스 (QueueClient.BeginReceiveBatch)를 사용하여 메시지를 읽으 려합니다. 큐 예상 메시지 수를 가지고 있으며, (QueueClient.AcceptMessageSession (correlationIdentifier)에서 읽을 수있는 세션이 있습니다.

난 아직도 RX 주위에 내 머리를 얻으려고,이 것 정말 선택 일까지.

을

Answer 1

는 푸른에 수신 확장을 추가 CloudFx 라이브러리가있다.

https://www.nuget.org/packages/Microsoft.Experience.CloudFx/ (업데이트 링크)

나는 우리가 테이블과 특히 (현재 CloudFx 라이브러리의 일부 스레드 누수를 발견 한 사실을 경고해야하지만 저장 장치 하나 - 그러나 Rx 확장이 필요하지 않습니다. 테이블 스토리지 2.0).