@Scheduled(fixedRate = REGISTRATION_SUPERVISION_INTERVAL_MS)
public void supervisionTask() {
checkRegistration() //
- .filter(isRegisterred -> !isRegisterred) //
+ .filter(isRegistrationOk -> !isRegistrationOk || !this.isRegisteredInEcs) //
.flatMap(isRegisterred -> registerTypesAndProducer()) //
.subscribe( //
null, //
}
private void handleRegistrationCompleted() {
- logger.debug("Registering types and producer succeeded");
+ logger.debug("Registering types and producer completed");
isRegisteredInEcs = true;
}
private void handleRegistrationFailure(Throwable t) {
- logger.warn("Registration failed {}", t.getMessage());
- isRegisteredInEcs = false;
+ logger.warn("Registration of producer failed {}", t.getMessage());
}
private Mono<Boolean> checkRegistration() {