aboutsummaryrefslogtreecommitdiffstats
path: root/lib/active_job
diff options
context:
space:
mode:
authorCristian Bica <cristian.bica@gmail.com>2014-06-03 01:04:08 +0300
committerCristian Bica <cristian.bica@gmail.com>2014-06-03 12:07:43 +0300
commiteaacb88fcb1428c84cd35575a177d2140a226ae2 (patch)
treef45f4f67d31e86d5ff0935c79ce9ee1482165ce9 /lib/active_job
parent8a3b137f95ad0ce459ce0eb9808850474da863d4 (diff)
downloadrails-eaacb88fcb1428c84cd35575a177d2140a226ae2.tar.gz
rails-eaacb88fcb1428c84cd35575a177d2140a226ae2.tar.bz2
rails-eaacb88fcb1428c84cd35575a177d2140a226ae2.zip
Raise exception for scheduling jobs in the inline adapter
Diffstat (limited to 'lib/active_job')
-rw-r--r--lib/active_job/queue_adapters/inline_adapter.rb12
1 files changed, 2 insertions, 10 deletions
diff --git a/lib/active_job/queue_adapters/inline_adapter.rb b/lib/active_job/queue_adapters/inline_adapter.rb
index d116520285..50d14a321d 100644
--- a/lib/active_job/queue_adapters/inline_adapter.rb
+++ b/lib/active_job/queue_adapters/inline_adapter.rb
@@ -6,16 +6,8 @@ module ActiveJob
job.new.execute *args
end
- def enqueue_at(job, timestamp, *args)
- Thread.new do
- begin
- interval = Time.now.to_f - timestamp
- sleep(interval) if interval > 0
- job.new.execute *args
- rescue => e
- ActiveJob::Base.logger.info "Error performing #{job}: #{e.message}"
- end
- end
+ def enqueue_at(*)
+ raise NotImplementedError.new("Use a queueing backend to enqueue jobs in the future. Read more at https://github.com/rails/activejob")
end
end
end