import java.util.Vector;
import org.immutables.value.Value.Immutable;
-import org.oransc.enrichment.controllers.consumer.ConsumerCallbacks;
-import org.oransc.enrichment.controllers.producer.ProducerCallbacks;
+import org.oransc.enrichment.controllers.a1e.A1eCallbacks;
+import org.oransc.enrichment.controllers.r1producer.ProducerCallbacks;
import org.oransc.enrichment.exceptions.ServiceException;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
private ProducerCallbacks producerCallbacks;
@Autowired
- private ConsumerCallbacks consumerCallbacks;
+ private A1eCallbacks consumerCallbacks;
@Autowired
private EiJobs eiJobs;
Collection<EiType> previousTypes =
previousDefinition != null ? previousDefinition.getEiTypes() : new ArrayList<>();
- producerCallbacks.restartEiJobs(producer, this.eiJobs) //
+ producerCallbacks.startEiJobs(producer, this.eiJobs) //
.collectList() //
.flatMapMany(list -> consumerCallbacks.notifyJobStatus(producer.getEiTypes())) //
.collectList() //