- // Returns TRUE if registration is correct
- private Mono<Boolean> checkRegistration() {
- return restClient.get(producerRegistrationUrl()) //
- .flatMap(this::isRegisterredInfoCorrect) //
- .onErrorResume(t -> Mono.just(Boolean.FALSE));
- }
-
- private Mono<Boolean> isRegisterredInfoCorrect(String registerredInfoStr) {
- ProducerRegistrationInfo registerredInfo = gson.fromJson(registerredInfoStr, ProducerRegistrationInfo.class);
- if (isEqual(producerRegistrationInfo(), registerredInfo)) {
- logger.trace("Already registered in ICS");
- return Mono.just(Boolean.TRUE);
- } else {
- return Mono.just(Boolean.FALSE);
- }
- }
-