diff options
| -rw-r--r-- | lib/active_job/queue_adapters/inline_adapter.rb | 8 |
1 files changed, 4 insertions, 4 deletions
diff --git a/lib/active_job/queue_adapters/inline_adapter.rb b/lib/active_job/queue_adapters/inline_adapter.rb index 414a918d2b..4f703a6c3f 100644 --- a/lib/active_job/queue_adapters/inline_adapter.rb +++ b/lib/active_job/queue_adapters/inline_adapter.rb @@ -6,14 +6,14 @@ module ActiveJob job.new.perform *Parameters.deserialize(args) end - def queue_at(job, ts, *args) + def queue_at(job, timestamp, *args) Thread.new do begin - interval = Time.now.to_f - ts + interval = Time.now.to_f - timestamp sleep(interval) if interval > 0 job.new.perform *Parameters.deserialize(args) - rescue => ex - ActiveJob::Base.logger.info "Error performing #{job}: #{ex.message}" + rescue => e + ActiveJob::Base.logger.info "Error performing #{job}: #{e.message}" end end end |