BroadcastActor.scala

class BroadcastActor(connector: QueueConnector[Future]) 
  extends Actor with ActorLogging {
  
  private var consumers: Set[ActorRef] = Set()

  override def receive: Receive = {
    case Subscribe(actor) => consumers += actor
    case Received(msg) =>
      consumers.foreach(_ ! msg)
  }
}