mirror of
https://github.com/rails/rails.git
synced 2022-11-09 12:12:34 -05:00
3cc93de6ad
The serializer should be set up in `after_initialize` so that it work properly even if the user specifies serializer with initializers. Also, since `custom_serializers` is `Array`, it needs to be flattened before setting the value.
45 lines
1.2 KiB
Ruby
45 lines
1.2 KiB
Ruby
# frozen_string_literal: true
|
|
|
|
require "global_id/railtie"
|
|
require "active_job"
|
|
|
|
module ActiveJob
|
|
# = Active Job Railtie
|
|
class Railtie < Rails::Railtie # :nodoc:
|
|
config.active_job = ActiveSupport::OrderedOptions.new
|
|
config.active_job.custom_serializers = []
|
|
|
|
initializer "active_job.logger" do
|
|
ActiveSupport.on_load(:active_job) { self.logger = ::Rails.logger }
|
|
end
|
|
|
|
initializer "active_job.custom_serializers" do |app|
|
|
config.after_initialize do
|
|
custom_serializers = app.config.active_job.delete(:custom_serializers)
|
|
ActiveJob::Serializers.add_serializers custom_serializers
|
|
end
|
|
end
|
|
|
|
initializer "active_job.set_configs" do |app|
|
|
options = app.config.active_job
|
|
options.queue_adapter ||= :async
|
|
|
|
ActiveSupport.on_load(:active_job) do
|
|
options.each do |k, v|
|
|
k = "#{k}="
|
|
send(k, v) if respond_to? k
|
|
end
|
|
end
|
|
end
|
|
|
|
initializer "active_job.set_reloader_hook" do |app|
|
|
ActiveSupport.on_load(:active_job) do
|
|
ActiveJob::Callbacks.singleton_class.set_callback(:execute, :around, prepend: true) do |_, inner|
|
|
app.reloader.wrap do
|
|
inner.call
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|
|
end
|