requeue einen Sweatshop-Job in RabbitMQ

Question

Ich arbeite an einer Rails-Anwendung, wo Kundenrückerstattungen an einen Sweatshop Arbeiter übergeben werden. Wenn eine Rückerstattung fehlschlägt (weil wir den Zahlungsprozessor zu diesem Zeitpunkt nicht erreichen können), möchte ich den Auftrag erneut anfordern.

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 

Gibt es einen besseren Weg als oben? Ich habe in RabbitMQ keine "Verzögerung" -Funktion gefunden, und dies sind die besten Lösungen, die ich bisher entwickelt habe. Ich möchte eine beschäftigte Schleife vermeiden, während ich requeueeing.

Answer 1

Es ist nicht wie AMQP scheint (oder zumindest RabbitMQ) unterstützt die Idee von "diesen Job verzögern." Daher scheint der Ansatz, den gleichen Job innerhalb des Arbeiters erneut einzutragen, wenn er fehlschlägt, zur Zeit die beste Lösung zu sein.

Ich habe den Code in einer Demoumgebung arbeiten und es erfüllt meine Bedürfnisse so weit.

Answer 2

Haben Sie einen zeitgesteuerten Lieferservice? Sie würden die Nachricht senden, um als Payload zu liefern, verpackt mit einer Zeit bis zur Auslieferung, und der Dienst würde die Nachricht beibehalten, bis die angegebene Zeit erreicht wurde. Nichts dergleichen existiert auf dem RabbitMQ-Server oder in einer der AMQP-Client-Bibliotheken, soweit mir bekannt ist, aber es wäre eine nützliche Sache zu haben.

Answer 3

Haben Sie Dinge wie Ruote und Minion angeschaut?

Einige Links hier: http://delicious.com/alexisrichardson/rabbitmq+work+ruby

Sie auch Sellerie versuchen könnten, die nicht nativen Rubin spricht aber HTTP + JSON spricht.

Alle oben genannten arbeiten mit RabbitMQ, so kann Ihnen helfen.

Prost

alexis