Includes the ability to override the default queue name and prefix.
# File activejob/lib/active_job/queue_name.rb, line 41 def queue_as(part_name = nil, &block) if block_given? self.queue_name = block else self.queue_name = queue_name_from_part(part_name) end end
Specifies the name of the queue to process the job on.
class PublishToFeedJob < ActiveJob::Base queue_as :feeds def perform(post) post.to_feed! end end
Can be given a block that will evaluate in the context of the job allowing self.arguments
to be accessed so that a dynamic queue name can be applied:
class PublishToFeedJob < ApplicationJob queue_as do post = self.arguments.first if post.paid? :paid_feeds else :feeds end end def perform(post) post.to_feed! end end
© 2004–2019 David Heinemeier Hansson
Licensed under the MIT License.