RabbitMQ

Question

'da bir terfi işi yeniden işleme Müşteri geri ödemelerinin bir Sweatshop çalışanına teslim edildiği bir Rails uygulaması üzerinde çalışıyorum. Geri ödeme başarısız olursa (o anda ödeme işlemcisine ulaşamıyoruz çünkü) işi yeniden yapmak istiyorum.

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 

Bunu yapmaktan daha iyi bir yolu var mı? RabbitMQ'da hiçbir "gecikme" özelliği bulamadım ve bu şimdiye kadar ortaya koyduğum en iyi çözüm. Requeueing sırasında yoğun bir döngüden kaçınmak istiyorum.

Answer 1

Alexis fikrini desteklediğini "Bu işi geciktirir." Yani aynı işi tekrar işten atma yaklaşımı, işçinin içinde başarısız olursa, bu zamanda en iyi çözüm gibi görünüyor.

Kodun bir demo ortamında çalışıyorum ve şu ana kadar gereksinimlerim karşılanıyor.

Answer 2

Zamanında teslimat hizmeti var mı? İletiyi, gönderilecek bir teslim ile sarılmış olarak teslim edecek şekilde gönderirsiniz ve belirtilen zamana ulaşılana kadar servisin mesajı bekler. RabbitMQ sunucusunda ya da AMQP istemci kütüphanelerinden herhangi birinin, bildiğim kadarıyla var olduğu gibi bir şey yok, ama sahip olmak yararlı bir şey olurdu.

Answer 3

Ruote ve Minion gibi şeylere baktınız mı? Burada

bazı bağlantılar: http://delicious.com/alexisrichardson/rabbitmq+work+ruby

Ayrıca yerli Ruby bilmiyor ama HTTP + JSON konuşur kereviz deneyebilirsin.

Yukarıdaki tüm çalışmalar RabbitMQ ile size yardımcı olabilir.

Alkış

O AMQP (veya en azından RabbitMQ) gibi görünmüyor