Simple Async ActiveSupport::Notification example

initializer_notification_center.rb

# config/initializer/notification_center.rb
NotificationCenter.queue
NotificationCenter.thread

ActiveSupport::Notifications.subscribe /(.)+\.notification/i do |*args|
  NotificationCenter.queue << args
end

notification_center.rb

# lib/notification_center.rb
require 'thread'
require 'active_support/notifications'

module NotificationCenter

  def self.logger
    Rails.logger
  end

  def self.queue
    @queue ||= Queue.new
  end

  def self.thread
    @thread ||= Thread.new do
      while args = queue.pop
        logger.fatal "\n\n\n\n"
        event = ActiveSupport::Notifications::Event.new(*args)
        logger.fatal "[#{event.name}] Starting Event"
        logger.fatal "[#{event.name}] #{args}"
        logger.fatal "[#{event.name}] #{event.duration}"
        logger.fatal "[#{event.name}] #{event.payload}"
        logger.fatal "\n\n\n\n"
      end
    end
  end

  def self.finish!
    queue << nil
    thread.join
    @thread = nil
    thread
  end
end

somewhere.rb

# somewhere in the code
info = {
      user: "nhocki",
      email: "what",
      message: "What's this?"
    }
ActiveSupport::Notifications.notifier.instrument("fail.notification", :extra => info)