lib/resque_spec/scheduler.rb in resque_spec-0.12.1 vs lib/resque_spec/scheduler.rb in resque_spec-0.12.2

- old
+ new

@@ -33,10 +33,11 @@ ResqueSpec.remove_delayed(klass, *args) end end def enqueue_at(time, klass, *args) + is_time?(time) perform_or_store(schedule_queue_name(klass), :class => klass.to_s, :time => time, :stored_at => Time.now, :args => args) end def enqueue_in(time, klass, *args) enqueue_at(Time.now + time, klass, *args) @@ -55,9 +56,13 @@ def schedule_for(klass) queue_by_name(schedule_queue_name(klass)) end private + + def is_time?(time) + time.to_i + end def schedule_queue_name(klass) "#{queue_name(klass)}_scheduled" end end