lib/resque/scheduler.rb in resque-scheduler-1.0.5 vs lib/resque/scheduler.rb in resque-scheduler-1.0.6

@@ -1,6 +1,5 @@
-require 'rufus-scheduler'
 require 'rufus/scheduler'
 require 'thwait'
 
 module Resque
 
@@ -69,11 +68,11 @@
             item = nil
             begin
               handle_shutdown do
                 if item = Resque.next_item_for_timestamp(timestamp)
                   log "queuing #{item['class']} [delayed]"
-                  queue = item['queue'] || queue_from_class(constantize(item['class']))
+                  queue = item['queue'] || Resque.queue_from_class(constantize(item['class']))
                   Job.create(queue, item['class'], *item['args'])
                 end
               end
             # continue processing until there are no more ready items in this timestamp
             end while !item.nil?
@@ -134,6 +133,6 @@
 
     end
 
   end
 
-end
\ No newline at end of file
+end