Change-Id: Iec4739aa7fa48c69f8c6753a95cecab0cabdf7a0
Signed-off-by: PatrikBuhr <patrik.buhr@est.tech>
Issue-ID: NONRTRIC-542
.doOnNext(resp -> logger.debug("Job subscription {} started OK {}", infoJob.getId(), producer.getId())) //
.onErrorResume(throwable -> {
producer.setJobDisabled(infoJob);
.doOnNext(resp -> logger.debug("Job subscription {} started OK {}", infoJob.getId(), producer.getId())) //
.onErrorResume(throwable -> {
producer.setJobDisabled(infoJob);
- logger.warn("Job subscription failed {}", producer.getId(), throwable.toString());
+ logger.warn("Job subscription failed id: {} url: {}, reason: {}", producer.getId(),
+ producer.getJobCallbackUrl(), throwable.toString());
return Mono.empty();
}) //
.doOnNext(resp -> producer.setJobEnabled(infoJob));
return Mono.empty();
}) //
.doOnNext(resp -> producer.setJobEnabled(infoJob));