Sha256: 3ec683e8adfa72015b43ca9d1c262951a17656702b7a4f8e4124a6204b39c117
Contents?: true
Size: 1.45 KB
Versions: 12
Compression:
Stored size: 1.45 KB
Contents
module Delayed
module Backend
class JobPreparer
attr_reader :options, :args
def initialize(*args)
@options = args.extract_options!.dup
@args = args
end
def prepare
set_payload
set_queue_name
set_priority
handle_deprecation
options
end
private
def set_payload
options[:payload_object] ||= args.shift
end
def set_queue_name
if options[:queue].nil? && options[:payload_object].respond_to?(:queue_name)
options[:queue] = options[:payload_object].queue_name
else
options[:queue] ||= Delayed::Worker.default_queue_name
end
end
def set_priority
queue_attribute = Delayed::Worker.queue_attributes[options[:queue]]
options[:priority] ||= (queue_attribute && queue_attribute[:priority]) || Delayed::Worker.default_priority
end
def handle_deprecation
if args.size > 0
warn '[DEPRECATION] Passing multiple arguments to `#enqueue` is deprecated. Pass a hash with :priority and :run_at.'
options[:priority] = args.first || options[:priority]
options[:run_at] = args[1]
end
# rubocop:disable GuardClause
unless options[:payload_object].respond_to?(:perform)
raise ArgumentError, 'Cannot enqueue items which do not respond to perform'
end
# rubocop:enabled GuardClause
end
end
end
end
Version data entries
12 entries across 12 versions & 1 rubygems