From c9487ed6aff76693f33ff89e466ba944297681d3 Mon Sep 17 00:00:00 2001
From: Yehuda Katz <wycats@gmail.com>
Date: Wed, 28 Oct 2009 01:58:33 -0700
Subject: Change Event#thread_id to #transaction_id. Defaults to one
 "transaction" per thread but you can explicitly declare the start of a new
 one. This makes it possible for each request to have it own id.

---
 activesupport/lib/active_support/notifications.rb | 25 +++++++++++------------
 1 file changed, 12 insertions(+), 13 deletions(-)

(limited to 'activesupport/lib/active_support/notifications.rb')

diff --git a/activesupport/lib/active_support/notifications.rb b/activesupport/lib/active_support/notifications.rb
index bf668964f5..9eae3bebe2 100644
--- a/activesupport/lib/active_support/notifications.rb
+++ b/activesupport/lib/active_support/notifications.rb
@@ -16,8 +16,8 @@ module ActiveSupport
   #
   #   @events = []
   #
-  #   ActiveSupport::Notifications.subscribe do |event|
-  #     @events << event
+  #   ActiveSupport::Notifications.subscribe do |*args|
+  #     @events << ActiveSupport::Notifications::Event.new(*args)
   #   end
   #
   #   ActiveSupport::Notifications.instrument(:render, :extra => :information) do
@@ -25,7 +25,6 @@ module ActiveSupport
   #   end
   #
   #   event = @events.first
-  #   event.class     #=> ActiveSupport::Notifications::Event
   #   event.name      #=> :render
   #   event.duration  #=> 10 (in miliseconds)
   #   event.result    #=> "Foo"
@@ -45,7 +44,7 @@ module ActiveSupport
     mattr_accessor :queue
 
     class << self
-      delegate :instrument, :transaction_id, :generate_id, :to => :instrumenter
+      delegate :instrument, :transaction_id, :transaction, :to => :instrumenter
 
       def instrumenter
         Thread.current[:notifications_instrumeter] ||= Instrumenter.new(publisher)
@@ -118,15 +117,15 @@ module ActiveSupport
     end
 
     class Event
-      attr_reader :name, :time, :end, :thread_id, :result, :payload
-
-      def initialize(name, start, ending, result, thread_id, payload)
-        @name      = name
-        @payload   = payload.dup
-        @time      = start
-        @thread_id = thread_id
-        @end       = ending
-        @result    = result
+      attr_reader :name, :time, :end, :transaction_id, :result, :payload
+
+      def initialize(name, start, ending, result, transaction_id, payload)
+        @name           = name
+        @payload        = payload.dup
+        @time           = start
+        @transaction_id = transaction_id
+        @end            = ending
+        @result         = result
       end
 
       def duration
-- 
cgit v1.2.3