module ActiveSupport::Notifications::Fanout::Subscribers

def self.new(pattern, listener)
  if listener.respond_to?(:start) and listener.respond_to?(:finish)
    subscriber = Evented.new pattern, listener
  else
    subscriber = Timed.new pattern, listener
  end
  unless pattern
    AllMessages.new(subscriber)
  else
    subscriber
  end
end