lib/belated/queue.rb in belated-0.5.1 vs lib/belated/queue.rb in belated-0.5.2
- old
+ new
@@ -14,10 +14,11 @@
@queue = queue
self.future_jobs = future_jobs
end
def push(job)
- if job.at.nil? || job.at <= Time.now.utc
+ if job == :shutdown || job.at.nil? ||
+ job.at <= Time.now.utc
@queue.push(job)
else
@future_jobs << job
end
end