aboutsummaryrefslogtreecommitdiffstats
path: root/lib/active_job/queue_adapters/inline_adapter.rb
diff options
context:
space:
mode:
authorDavid Heinemeier Hansson <david@loudthinking.com>2014-05-20 19:15:57 +0200
committerDavid Heinemeier Hansson <david@loudthinking.com>2014-05-20 19:15:57 +0200
commit6bd45aaae1e244591faf784880709e5e64d18d21 (patch)
tree94930bef7349aa52d8d89f933b5499b58934a32b /lib/active_job/queue_adapters/inline_adapter.rb
parentb367830af7fb75cd59863b3a1311d4a5bc4b37a8 (diff)
downloadrails-6bd45aaae1e244591faf784880709e5e64d18d21.tar.gz
rails-6bd45aaae1e244591faf784880709e5e64d18d21.tar.bz2
rails-6bd45aaae1e244591faf784880709e5e64d18d21.zip
Style
Diffstat (limited to 'lib/active_job/queue_adapters/inline_adapter.rb')
-rw-r--r--lib/active_job/queue_adapters/inline_adapter.rb8
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