- private Mono<String> startEiJob(EiProducer producer, EiJob eiJob) {
- Retry retrySpec = Retry.fixedDelay(1, Duration.ofSeconds(1));
- return producerCallbacks.startEiJob(producer, eiJob, retrySpec);
- }
-
- private Flux<EiJob> getEiJobs(EiProducer producer) {
- return Flux.fromIterable(producer.getEiTypes()) //
- .flatMap(eiType -> Flux.fromIterable(eiJobs.getJobsForType(eiType)));
+ private Flux<InfoJob> getEiJobs(InfoProducer producer) {
+ return Flux.fromIterable(producer.getInfoTypes()) //
+ .flatMap(infoType -> Flux.fromIterable(infoJobs.getJobsForType(infoType)));