lib/qe/resque.rb in qe-0.2.0 vs lib/qe/resque.rb in qe-0.2.1
- old
+ new
@@ -1,7 +1,8 @@
require "qe"
require "resque"
+require "resque_scheduler"
module Qe
class Resque
class Worker
def self.perform(*args)
@@ -10,9 +11,15 @@
end
def self.enqueue(worker, options = {})
Worker.instance_variable_set "@queue", worker.queue
::Resque.enqueue Worker, worker.name, options
+ end
+
+ def self.schedule(worker, run_at, options = {})
+ Worker.instance_variable_set "@queue", worker.queue
+
+ ::Resque.enqueue_at(run_at, Worker, worker.name, options)
end
end
self.adapter = Resque
end