RabbitDataFlow.scala

object RabbitToRabbitFlow extends App {
   implicit val actorSystem = ActorSystem("rabbit-akka")
   implicit val materializer = ActorMaterializer()

   val config = ConfigFactory.load("application.conf")

   val sourceConnection = Connection(config.getConfig("source"))
   val targetConnection = Connection(config.getConfig("target"))

   val rabbitConsumer = Source.fromPublisher(sourceConnection.consume(config.getString("source.queue_name")))
   val rabbitPublisher = Sink.fromSubscriber(toLoggedSubscriber(targetConnection.publish(config.getString("target.exchange"))))

   rabbitConsumer via deliveryToMessageMapping(config.getString("target.routing_key")) to rabbitPublisher run()
}