+ public Flux<String> startEiJobs(EiProducer producer, EiJobs eiJobs) {
+ final int maxNoOfParalellRequests = 10;
+ Retry retrySpec = Retry.backoff(3, Duration.ofSeconds(1));
+
+ return Flux.fromIterable(producer.getEiTypes()) //
+ .flatMap(type -> Flux.fromIterable(eiJobs.getJobsForType(type))) //
+ .flatMap(job -> startEiJob(producer, job, retrySpec), maxNoOfParalellRequests);
+ }
+
+ public Mono<String> startEiJob(EiProducer producer, EiJob eiJob, Retry retrySpec) {