Reactive consumer of events coming from a Rabbit MQ queue using Akka streams. - View it on GitHub