मैं नेट प्रोग्राम में ActiveMQ का उपयोग कर रहा हूं और मुझे संदेश-ईवेंट के साथ बाढ़ आ रही है।मैं अपने सी # ऐप में ActiveMQ से आने वाले संदेशों की मात्रा को कैसे थका सकता हूं?
संक्षेप में जब मुझे कतार-घटना 'ऑन मैसेज (इमेजेज प्राप्त संदेश) प्राप्त होता है, तो मैंने संदेश को एक आंतरिक कतार में डाल दिया जिसमें से एक्स थ्रेड उनकी बात करते हैं।
पहले मेरे पास था: सत्र को बनाते समय 'स्वीकृति मोड। ऑटो स्वीकृति' तो मुझे लगता है कि कतार में सभी संदेश चूस गए हैं और मेमोरी कतार में डाल दिया गया है (जो दुर्घटना के बाद से जोखिम भरा है, सब कुछ है खो गया)।
तो मैंने उपयोग किया: सत्र स्वीकार करते समय 'पावती संदेश। क्लाइंट स्वीकार करें', और जब कोई कार्यकर्ता संदेश के साथ तैयार होता है तो यह संदेश पर 'प्रतिबद्ध()' विधि कहता है। हालांकि, अभी भी सभी संदेश कतार से नीचे चूस गए हैं।
मैं इसे कैसे कॉन्फ़िगर कर सकता हूं कि केवल एक एक्स मात्रा में संदेशों को संसाधित किया जा रहा है या आंतरिक कतार में हैं, और यह कि सबकुछ तुरंत 'डाउनलोड नहीं किया जा रहा है'?
हालांकि मैंने कभी भी ActiveMQ को छुआ नहीं है - क्या आप इसे चारों ओर फ़्लिप नहीं कर सकते हैं: ActiveMQ श्रोताओं के साथ एन थ्रेड सेट करें, और सुनो ईवेंट के भीतर संदेशों को संसाधित करें? –
@ विल ह्यूजेस: मेरा पूरा कार्यक्रम एक असीमित तरीके से लिखा गया है। तो कॉलबैक के साथ भी डीबी एक्सेस असीमित रूप से किया जाता है। तो मैं इस कार्यक्रम में नहीं रह सकता। – Toad