एमएसएमक्यू संदेश के लिए प्रतिक्रियाशील विस्तार (आरएक्स) का उपयोग एसिंक पैटर्न (queue.BeginReceive, queue.EndReceive)

Question

का उपयोग करके प्राप्त होता है। मैं अपनी परियोजनाओं पर घटनाओं के लिए आरएक्स का उपयोग कर रहा हूं और सॉकेट प्रोग्रामिंग के लिए समर्पित हूं और इसका अच्छा हिस्सा है अच्छा कर रहा हूँ। मेरा कोड, प्रदर्शन लाभ और निष्पादन और व्याख्या करने के लिए बहुत बेहतर प्रबंधन।

हाल ही में मैं अपने प्रोजेक्ट के प्रक्रिया प्रवाह मैं कहाँ (सॉकेट संचालन से) आने वाले सभी डेटा डंप करने की जरूरत है कतार में (MSMQ कार्यान्वयन का उपयोग के रूप में कतार के लिए फैसला किया है) को संशोधित करने के लिए है।

चूंकि एमएसएमक्यू कतार से संदेशों को हटाने के लिए एसिंक कॉल प्रदान करता है (लेकिन एक व्यापक पैटर्न में)। अब मैं इस उद्देश्य के लिए आरएक्स का उपयोग करने के लिए संघर्ष कर रहा हूं, लेकिन ऐसा करने में सक्षम हूं।

प्रश्न: क्या कोई मुझे एसिंक पैटर्न का उपयोग कर कतार से प्राप्त संदेश के लिए आरएक्स को लागू करने के लिए एक स्वच्छ कोड उदाहरण दे सकता है।

मैं async ऑपरेटर की तरह इस

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

अग्रिम धन्यवाद कुछ करने के लिए MSMQ अनुरूप के लिए कार्यान्वयन की जरूरत है। * चियर्स * आरएक्स और .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();