RabbitMQ

Question

मैं एक रेल आवेदन जहां ग्राहक रिफंड एक कठोर परिश्रम कार्यकर्ता को सौंप दिया जाता है पर काम कर रहा हूँ में एक sweatshop काम requeue। यदि धनवापसी विफल हो जाती है (क्योंकि हम उस समय भुगतान प्रोसेसर तक नहीं पहुंच सकते हैं) मैं नौकरी की आवश्यकता चाहता हूं।

class RefundWorker < Sweatshop::Worker 

def process_refund(job) 
    if refund 
    Transaction.find(job[:transaction]).update_attributes(:status => 'completed') 
    else 
    sleep 3 
    RefundWorker.async_process_refund(job) # requeue the job 
    end 
end 

क्या ऊपर से ऐसा करने का कोई बेहतर तरीका है? मुझे RabbitMQ में कोई "देरी" सुविधा नहीं मिली है, और यह अब तक का सबसे अच्छा समाधान है। मैं आवश्यकता के दौरान व्यस्त लूप से बचना चाहता हूं।

Answer 1

यह AMQP (या कम से कम RabbitMQ) की तरह प्रतीत नहीं होता है के विचार का समर्थन करता है "इस काम में देरी।" तो कार्यकर्ता के अंदर से एक ही नौकरी फिर से कतारबद्ध करने का दृष्टिकोण यदि यह विफल रहता है तो इस समय सबसे अच्छा समाधान प्रतीत होता है।

मैं एक डेमो माहौल में काम करने कोड है और यह अब तक मेरी जरूरतों को पूरा करने।

Answer 2

समय-डिलीवरी सेवा है? आप संदेश को पेलोड के रूप में वितरित करने के लिए भेज देंगे, जो समय-समय पर डिलीवरी के साथ लपेटा जाएगा, और सेवा निर्दिष्ट समय तक पहुंचने तक संदेश पर रखेगी। जैसा कि मुझे पता है, खरगोश एमक्यू सर्वर या किसी भी एएमक्यूपी क्लाइंट पुस्तकालयों में ऐसा कुछ भी नहीं है, लेकिन यह एक उपयोगी बात होगी।

Answer 3

आप जुड़वा और मिनियन जैसी चीजों को देखा है?

यहाँ कुछ लिंक: http://delicious.com/alexisrichardson/rabbitmq+work+ruby

तुम भी अजवाइन जो देशी रूबी बात नहीं करता लेकिन HTTP + JSON बात करता है की कोशिश कर सकते।

RabbitMQ के साथ ऊपर काम के सभी है, तो आप मदद कर सकते हैं।

चीयर्स

एलेक्सिस