aboutsummaryrefslogtreecommitdiffstats
path: root/lib/active_job/queue_adapters
diff options
context:
space:
mode:
authorMike Perham <mperham@gmail.com>2014-05-20 09:37:38 -0700
committerMike Perham <mperham@gmail.com>2014-05-20 09:37:38 -0700
commit0e60e8878378f29f63e8d7e5ee0455e011ac3840 (patch)
tree02af922f0178709a0d926b114ef592a48439917f /lib/active_job/queue_adapters
parent897f86b8d13cd0583dc5e579ed56c6f4064330db (diff)
downloadrails-0e60e8878378f29f63e8d7e5ee0455e011ac3840.tar.gz
rails-0e60e8878378f29f63e8d7e5ee0455e011ac3840.tar.bz2
rails-0e60e8878378f29f63e8d7e5ee0455e011ac3840.zip
More feedback
Diffstat (limited to 'lib/active_job/queue_adapters')
-rw-r--r--lib/active_job/queue_adapters/inline_adapter.rb3
1 files changed, 1 insertions, 2 deletions
diff --git a/lib/active_job/queue_adapters/inline_adapter.rb b/lib/active_job/queue_adapters/inline_adapter.rb
index 8a2c7d9d92..414a918d2b 100644
--- a/lib/active_job/queue_adapters/inline_adapter.rb
+++ b/lib/active_job/queue_adapters/inline_adapter.rb
@@ -7,14 +7,13 @@ module ActiveJob
end
def queue_at(job, ts, *args)
- # TODO better error handling?
Thread.new do
begin
interval = Time.now.to_f - ts
sleep(interval) if interval > 0
job.new.perform *Parameters.deserialize(args)
rescue => ex
- ActiveJob::Base.logger "Error performing #{job}: #{ex.message}"
+ ActiveJob::Base.logger.info "Error performing #{job}: #{ex.message}"
end
end
end