diff --git a/services/src/main/java/io/scalecube/services/Microservices.java b/services/src/main/java/io/scalecube/services/Microservices.java index 0c12a609b..4ca987a41 100644 --- a/services/src/main/java/io/scalecube/services/Microservices.java +++ b/services/src/main/java/io/scalecube/services/Microservices.java @@ -47,8 +47,6 @@ import reactor.core.publisher.MonoProcessor; import reactor.core.scheduler.Scheduler; import reactor.core.scheduler.Schedulers; -import sun.misc.Signal; -import sun.misc.SignalHandler; /** * The ScaleCube-Services module enables to provision and consuming microservices in a cluster. @@ -221,7 +219,6 @@ private Mono start() { // return original error then shutdown return Mono.whenDelayError(Mono.error(ex), shutdown()).cast(Microservices.class); }) - .doOnSuccess(m -> listenJvmShutdown()) .doOnSuccess(m -> LOGGER.info("[{}][start] Started", id)) .doOnTerminate(scheduler::dispose); } @@ -291,12 +288,6 @@ public Mono onShutdown() { return onShutdown; } - private void listenJvmShutdown() { - SignalHandler handler = signal -> shutdown.onComplete(); - Signal.handle(new Signal("TERM"), handler); - Signal.handle(new Signal("INT"), handler); - } - private Mono doShutdown() { return Mono.defer( () -> {