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