diff options
author | Dennis Schoen <dennis.schoen@xing.com> | 2014-05-09 11:16:18 +0200 |
---|---|---|
committer | Dennis Schoen <dennis.schoen@xing.com> | 2014-05-09 11:16:18 +0200 |
commit | b50468d13dfc5d9ba1abe9b097d80b0191f6933f (patch) | |
tree | 841bb47b982aa27cc55063cb994a4118388526ae /activesupport/lib/active_support | |
parent | 83e0544204a1b0125af15e1ea0e54aa30b2266ab (diff) | |
download | rails-b50468d13dfc5d9ba1abe9b097d80b0191f6933f.tar.gz rails-b50468d13dfc5d9ba1abe9b097d80b0191f6933f.tar.bz2 rails-b50468d13dfc5d9ba1abe9b097d80b0191f6933f.zip |
Fixed duplicate subscribers in ActiveSupport::Subscriber
ActiveSupport::Subscriber no longer creates multiple subscribers when
you redefine a method.
Diffstat (limited to 'activesupport/lib/active_support')
-rw-r--r-- | activesupport/lib/active_support/subscriber.rb | 11 |
1 files changed, 10 insertions, 1 deletions
diff --git a/activesupport/lib/active_support/subscriber.rb b/activesupport/lib/active_support/subscriber.rb index 4b9b48539f..4306c2ac8d 100644 --- a/activesupport/lib/active_support/subscriber.rb +++ b/activesupport/lib/active_support/subscriber.rb @@ -64,12 +64,21 @@ module ActiveSupport def add_event_subscriber(event) return if %w{ start finish }.include?(event.to_s) - notifier.subscribe("#{event}.#{namespace}", subscriber) + pattern = "#{event}.#{namespace}" + + # don't add multiple subscribers (eg. if methods are redefined) + return if subscriber.patterns.include?(pattern) + + subscriber.patterns << pattern + notifier.subscribe(pattern, subscriber) end end + attr_reader :patterns + def initialize @queue_key = [self.class.name, object_id].join "-" + @patterns = [] super end |