Job consumer logs to Rails.logger by default

activesupport/lib/active_support/queueing.rb

@@ -64,9 +64,12 @@ def push(job)
   # queue and joins the thread, which will ensure that all jobs
   # are executed before the process finally dies.
   class ThreadedQueueConsumer
+    attr_accessor :logger
+
     def initialize(queue, options = {})
       @queue = queue
-      @logger = options[:logger] || Logger.new($stderr)
+      @logger = options[:logger]
+      @fallback_logger = Logger.new($stderr)
     end
 
     def start
@@ -96,7 +99,7 @@ def run(job)
     end
 
     def handle_exception(job, exception)
-      @logger.error "Job Error: #{job.inspect}\n#{exception.message}\n#{exception.backtrace.join("\n")}"
+      (logger || @fallback_logger).error "Job Error: #{job.inspect}\n#{exception.message}\n#{exception.backtrace.join("\n")}"
     end
   end
 end

railties/lib/rails/application/finisher.rb

@@ -99,6 +99,7 @@ module Finisher
       initializer :activate_queue_consumer do |app|
         if config.queue.class == ActiveSupport::Queue
           app.queue_consumer = config.queue_consumer || config.queue.consumer
+          app.queue_consumer.logger ||= Rails.logger if app.queue_consumer.respond_to?(:logger=)
           app.queue_consumer.start
           at_exit { app.queue_consumer.shutdown }
         end

railties/test/application/queue_test.rb

@@ -78,6 +78,7 @@ def ran?
 
       assert_nil Rails.application.config.queue_consumer
       assert_kind_of ActiveSupport::ThreadedQueueConsumer, Rails.application.queue_consumer
+      assert_equal Rails.logger, Rails.application.queue_consumer.logger
     end
 
     test "attempting to marshal a queue will raise an exception" do