logger.warn("Registration of producer failed {}", t.getMessage());
}
+ // Returns TRUE if registration is correct
private Mono<Boolean> checkRegistration() {
final String url = applicationConfig.getEcsBaseUrl() + "/data-producer/v1/info-producers/" + PRODUCER_ID;
return restClient.get(url) //
private Mono<String> registerTypesAndProducer() {
final int CONCURRENCY = 20;
- final String producerUrl = applicationConfig.getEcsBaseUrl() + "/data-producer/v1/info-producers/"
- + PRODUCER_ID;
+ final String producerUrl =
+ applicationConfig.getEcsBaseUrl() + "/data-producer/v1/info-producers/" + PRODUCER_ID;
return Flux.fromIterable(this.types.getAll()) //
.doOnNext(type -> logger.info("Registering type {}", type.getId())) //