pelted · May 16, 2022 18:01 · Jun 1, 2012
diff --git a/initializer_notification_center.rb b/initializer_notification_center.rb
@@ -0,0 +1,7 @@
+# config/initializer/notification_center.rb
+NotificationCenter.queue
+NotificationCenter.thread
+
+ActiveSupport::Notifications.subscribe /(.)+\.notification/i do |*args|
+  NotificationCenter.queue << args
+end
diff --git a/notification_center.rb b/notification_center.rb
@@ -0,0 +1,35 @@
+# 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
diff --git a/somewhere.rb b/somewhere.rb
@@ -0,0 +1,7 @@
+# somewhere in the code
+info = {
+      user: "nhocki",
+      email: "what",
+      message: "What's this?"
+    }
+ActiveSupport::Notifications.notifier.instrument("fail.notification", :extra => info)
No results found