lib/qe/qu.rb in qe-0.2.0 vs lib/qe/qu.rb in qe-0.2.1
- old
+ new
@@ -2,19 +2,21 @@
require "qu"
module Qe
class Qu
class Worker
- include ::Sidekiq::Worker
-
def self.perform(*args)
Qe::Worker.perform(*args)
end
end
def self.enqueue(worker, options = {})
Worker.instance_variable_set("@queue", worker.queue)
::Qu.enqueue Worker, worker.name, options
+ end
+
+ def self.schedule(*)
+ raise UnsupportedFeatureError, "scheduling isn't supported on Qu"
end
end
self.adapter = Qu
end