Fixed Microservices.CompositeServiceDiscovery.start0

Author: artem-v

services/src/main/java/io/scalecube/services/Microservices.java

@@ -650,7 +650,7 @@ private Mono<? extends Void> start0(String id, ServiceDiscovery discovery) {
               .subscribeOn(scheduler)
               .publishOn(scheduler)
               .doOnNext(event -> onDiscoveryEvent(microservices, event))
-              .doOnNext(sink::tryEmitNext)
+              .doOnNext(event -> sink.emitNext(event, RetryEmitFailureHandler.INSTANCE))
               .subscribe());
 
       return Mono.deferContextual(context -> discovery.start())