ruby-on-rails – delayed_job.从队列中删除作业

前端之家收集整理的这篇文章主要介绍了ruby-on-rails – delayed_job.从队列中删除作业前端之家小编觉得挺不错的,现在分享给大家,也给大家做个参考。
  1. class Radar
  2. include Mongoid::Document
  3. after_save :post_on_facebook
  4.  
  5. private
  6.  
  7. def post_on_facebook
  8. if self.user.settings.post_facebook
  9. Delayed::Job.enqueue(::FacebookJob.new(self.user,self.body,url,self.title),self.active_from)
  10. end
  11. end
  12.  
  13. end
  14.  
  15. class FacebookJob < Struct.new(:user,:body,:url,:title)
  16. include SocialPluginsHelper
  17.  
  18. def perform
  19. facebook_client(user).publish_Feed('',:message => body,:link => url,:name => title)
  20. end
  21. end

我想在特定日期执行post_on_facebook方法.我将此日期存储在“active_from”字段中.

上面的代码正常工作,工作在正确的日期执行.

但在某些情况下,我首先创建Radar对象并将一些作业发送到延迟作业队列.之后,我更新此对象并将另一个作业发送到延迟作业.

这是错误的行为,因为我不会在正确的时间执行一次工作.在这个实现中,我将有2个将被执行的作业.我怎么能删除以前的工作,所以只更新一个将被执行?

  1. Rails 3.0.7
  2. Delayed Job => 2.1.4 https://github.com/collectiveidea/delayed_job

ps:对不起我的英语我尽力做到最好

解决方法

听起来如果雷达对象更新并重新排队,您想要将任何作业排队.

Delayed :: Job.enqueue应该返回一个Delayed :: Job记录,这样你就可以从中获取ID并将其保存回雷达记录(在雷达文档上为它创建一个字段),这样你以后就可以轻松找到它了. .

您应该将其更改为before_save,这样您就不会进入无限循环的保存.

  1. before_save :post_on_facebook
  2.  
  3. def post_on_facebook
  4. if self.user.settings.post_facebook && self.valid?
  5.  
  6. # delete existing delayed_job if present
  7. Delayed::Job.find(self.delayed_job_id).destroy if self.delayed_job_id
  8.  
  9. # enqueue job
  10. dj = Delayed::Job.enqueue(
  11. ::FacebookJob.new(self.user,self.active_from
  12. )
  13.  
  14. # save id of delayed job on radar record
  15. self.delayed_job_id = dj.id
  16.  
  17. end
  18. end

猜你在找的Ruby相关文章