- public void notifyProducersJobDeleted(EiJob eiJob) {
- ProducerJobInfo request = new ProducerJobInfo(eiJob);
- String body = gson.toJson(request);
- for (EiProducer producer : getProducers(eiJob)) {
- restClient.post(producer.getJobDeletionCallbackUrl(), body) //
- .subscribe(notUsed -> logger.debug("Job deleted OK {}", producer.getId()), //
- throwable -> logger.warn("Job delete failed {}", producer.getId(), throwable.toString()), null);
+ public Mono<String> healthCheck(EiProducer producer) {
+ return restClient.get(producer.getProducerSupervisionCallbackUrl());
+ }
+
+ public void stopEiJob(EiJob eiJob, EiProducers eiProducers) {
+ for (EiProducer producer : getProducersForJob(eiJob, eiProducers)) {
+ String url = producer.getJobCallbackUrl() + "/" + eiJob.getId();
+ producer.setJobDisabled(eiJob);
+ restClient.delete(url) //
+ .subscribe(response -> logger.debug("Producer job deleted OK {}", producer.getId()), //
+ throwable -> logger.warn("Producer job delete failed {} {}", producer.getId(),
+ throwable.getMessage()),
+ null);