diff options
author | David Heinemeier Hansson <david@loudthinking.com> | 2014-05-20 19:15:57 +0200 |
---|---|---|
committer | David Heinemeier Hansson <david@loudthinking.com> | 2014-05-20 19:15:57 +0200 |
commit | 6bd45aaae1e244591faf784880709e5e64d18d21 (patch) | |
tree | 94930bef7349aa52d8d89f933b5499b58934a32b | |
parent | b367830af7fb75cd59863b3a1311d4a5bc4b37a8 (diff) | |
download | rails-6bd45aaae1e244591faf784880709e5e64d18d21.tar.gz rails-6bd45aaae1e244591faf784880709e5e64d18d21.tar.bz2 rails-6bd45aaae1e244591faf784880709e5e64d18d21.zip |
Style
-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 |