class ActiveSupport::Notifications::Fanout

def subscribe(pattern = nil, block = Proc.new)
  subscriber = Subscribers.new pattern, block
  synchronize do
    @subscribers << subscriber
    @listeners_for.clear
  end
  subscriber
end