From 0227af92b1851d5eac4cb423dc0c9935dbc733a3 Mon Sep 17 00:00:00 2001 From: Cristian Bica Date: Tue, 20 May 2014 14:41:14 +0300 Subject: Added logging capabilities --- lib/active_job/log_subscriber.rb | 19 +++++++++++++++++++ 1 file changed, 19 insertions(+) create mode 100644 lib/active_job/log_subscriber.rb (limited to 'lib/active_job/log_subscriber.rb') diff --git a/lib/active_job/log_subscriber.rb b/lib/active_job/log_subscriber.rb new file mode 100644 index 0000000000..81859d8da1 --- /dev/null +++ b/lib/active_job/log_subscriber.rb @@ -0,0 +1,19 @@ +module ActiveJob + class LogSubscriber < ActiveSupport::LogSubscriber + + def enqueue(event) + payload = event.payload + params = payload[:params] + adapter = payload[:adapter] + job = payload[:job] + + info "ActiveJob enqueued to #{adapter.name.demodulize} job #{job.name}: #{params.inspect}" + end + + def logger + ActiveJob::Base.logger + end + end +end + +ActiveJob::LogSubscriber.attach_to :active_job -- cgit v1.2.3