a simple EventStream in Actor

PubSub.scala

import akka.actor._

case class Feed(name: String)

class FeedSubscriber extends Actor {

  def receive = {
    case feed: Feed => println(s"""feed received at ${feed} ${self.path}""")
  }

}

object FeedStream extends App {

  val as = ActorSystem("FeedAS")

  val feedSub1 = as.actorOf(Props[FeedSubscriber], "fs1")
  val feedSub2 = as.actorOf(Props[FeedSubscriber], "fs2")
  as.eventStream.subscribe(feedSub1, classOf[Feed])
  as.eventStream.subscribe(feedSub2, classOf[Feed])

  def publishFeed(feed: Feed) = {
    as.eventStream.publish(feed)
  }

  publishFeed(Feed("feed1"))

}