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