val route = path("api" / "statements") {
      post {
        entity(as[String]) { payload: String =>
          complete(
            Source
              .single(payload)
              .map(s => ByteString(s))
              .runWith(amqpSink)
              .map(_ => HttpEntity(ContentTypes.`application/json`, "{}"))
          )
        }
      }
    }