Publish /Subscribe example using Akka EventStream and Scala