非同期パターン（queue.BeginReceive、queue.EndReceive）を使用してMSMQメッセージを受信するためのリアクティブエクステンション（Rx）の使用

Question

私のプロジェクトのイベント用にRxを使用しています。よくやって。コード、パフォーマンスの優位性を管理し、実行して解釈する方がはるかに優れています。

最近、私はすべての着信データを（ソケット操作から）待ち行列に入れる（待ち行列のために決定されたMSMQ実装を使用して）必要がある場合に、プロジェクトのプロセスフローを変更する必要があります。

MSMQはキューからメッセージをデキューするための非同期呼び出しを提供しますが（wierdパターン） 私は今この目的のためにRxを使用することに苦労していますが、そうすることができます。

質問：非同期パターンを使用するキューからのメッセージ受信用にRxを実装するためのクリーンなコード例があります。

私は事前にこの

var data = Observable.FromAsyncPattern<byte[]>(
         this.receiverSocket.BeginReceive, 
         this.receiverSocket.EndReceive(some parameters); 

のおかげのようなものに類似したMSMQのための非同期オペレータの実装を必要とします。 * Rxおよび.NETへ歓声 *

Answer 1

それはのような単純なものになります。

var queue = new System.Messaging.MessageQueue("test"); 
var fun = Observable.FromAsyncPattern((cb, obj) => queue.BeginReceive(TimeSpan.FromMinutes(10),obj,cb), a => queue.EndReceive(a)); 
var obs = fun();