requeue một công việc buôn bán tại RabbitMQ

Question

Tôi đang làm việc trên một ứng dụng Rails nơi hoàn trả khách hàng được giao cho một công nhân Sweatshop. Nếu khoản tiền hoàn lại không thành công (vì chúng tôi không thể liên lạc với bộ phận xử lý thanh toán tại thời điểm đó), tôi muốn thực hiện lại công việc.

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 

Có cách nào tốt hơn để thực hiện điều này không? Tôi đã không tìm thấy bất kỳ "chậm trễ" tính năng trong RabbitMQ, và đây là giải pháp tốt nhất tôi đã đưa ra cho đến nay. Tôi muốn tránh một vòng lặp bận rộn trong khi requeueing.

Answer 1

Nó không có vẻ như AMQP (hoặc ít nhất RabbitMQ) ủng hộ ý tưởng "trì hoãn công việc này." Vì vậy, cách tiếp cận để xếp hàng lại cùng một công việc từ bên trong công nhân nếu nó không có vẻ là giải pháp tốt nhất vào lúc này.

Tôi có mã hoạt động trong môi trường trình diễn và đáp ứng nhu cầu của tôi cho đến thời điểm này.

Answer 2

Có dịch vụ chuyển phát theo thời gian? Bạn sẽ gửi tin nhắn để phân phối dưới dạng tải trọng, được gói với thời gian giao hàng và dịch vụ sẽ giữ lại tin nhắn cho đến khi đạt đến thời gian đã chỉ định. Không có gì giống như vậy tồn tại trong máy chủ RabbitMQ hoặc bất kỳ thư viện máy khách AMQP nào, theo như tôi biết, nhưng nó sẽ là một điều hữu ích để có.

Answer 3

Bạn đã xem những thứ như Ruote và Minion chưa?

Một số liên kết ở đây: http://delicious.com/alexisrichardson/rabbitmq+work+ruby

Bạn cũng có thể thử Cần tây mà không nói mẹ đẻ Ruby nhưng không nói HTTP + JSON.

Tất cả công việc trên với RabbitMQ, vì vậy có thể giúp bạn.

Cheers

alexis