A Scala and Akka FSM based amqp client