lib/qe/beanstalk.rb in qe-0.2.0 vs lib/qe/beanstalk.rb in qe-0.2.1

@@ -13,9 +13,15 @@
 
     def self.enqueue(worker, options = {})
       Worker.queue worker.queue
       Backburner.enqueue Worker, worker.name, options
     end
+
+    def self.schedule(worker, run_at, options = {})
+      delay = run_at - Time.now
+      Worker.queue worker.queue
+      Backburner::Worker.enqueue Worker, [worker.name, options], :delay => delay
+    end
   end
 
   self.adapter = Beanstalk
 end