Fixed Microservices.CompositeServiceDiscovery.start0

scalecube · Apr 12, 2021 · b318b7a · b318b7a
1 parent 06fa7e5
commit b318b7a
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/services/src/main/java/io/scalecube/services/Microservices.java b/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())