class Celluloid::Notifications::Fanout

def publish(pattern, *args)
  listeners_for(pattern).each { |s| s.publish(pattern, *args) }
end