StatsApp.scala

implicit val connection = Connection()
val queue = Queue(queueName, durable = false, autoDelete = true)
val bindArgs = Map("x-match" -> "all", "type" -> "DiceRolled")

val resultFuture = for {
  _ <- connection.queueDeclare(queue)
  _ <- connection.queueBind(queueName, exchangeName, "", bindArgs)
} yield ()

resultFuture onComplete {
  case Success(_) =>
    Source(connection.consume(queueName))
      .map(_.message)
      .to(Sink(SubscriberActor.props(statsActor)))
      .run()(ActorFlowMaterializer())
  case Failure(ex) =>
    log.error("Cannot setup queue", ex)
    sys.exit(1)
}