2013-06-29 67 views

回答

1

我想你想看看resque after_perform掛鉤工作,這將給你的指示處理作業/完成

像這樣你的工作中

class MyJob 
    @queue = :my_job 

    def self.perform(*args) 
    .... your perform code ... 
    end 

    def self.after_perform(*args) 
    ... Write some code to setup a channel .. 
    end 

end 

這樣的after_perform鉤會在執行動作後執行completed/processed表示完成作業

我建議的是設置一個通道(使用pub/sublist),您的應用程序和resque工作,傳達給你的應用程序訂閱/拉數據,您可以識別基於該作業已完成,有效載荷/加工希望這有助於之間

感謝您