lib/qe/sidekiq.rb in qe-0.3.5 vs lib/qe/sidekiq.rb in qe-0.4.0

@@ -10,15 +10,15 @@
         Qe::Worker.perform(*args)
       end
     end
 
     def self.enqueue(worker, options = {})
-      Worker.sidekiq_options :queue => worker.queue
+      Worker.sidekiq_options worker.options.merge(:queue => worker.queue)
       Worker.perform_async(worker.name, options)
     end
 
     def self.schedule(worker, run_at, options = {})
-      Worker.sidekiq_options :queue => worker.queue
+      Worker.sidekiq_options worker.options.merge(:queue => worker.queue)
       Worker.perform_at(run_at, worker.name, options)
     end
   end
 
   self.adapter = Sidekiq