File tree Expand file tree Collapse file tree 1 file changed +0
-9
lines changed
services/src/main/java/io/scalecube/services Expand file tree Collapse file tree 1 file changed +0
-9
lines changed Original file line number Diff line number Diff line change 4747import reactor .core .publisher .MonoProcessor ;
4848import reactor .core .scheduler .Scheduler ;
4949import reactor .core .scheduler .Schedulers ;
50- import sun .misc .Signal ;
51- import sun .misc .SignalHandler ;
5250
5351/**
5452 * The ScaleCube-Services module enables to provision and consuming microservices in a cluster.
@@ -221,7 +219,6 @@ private Mono<Microservices> start() {
221219 // return original error then shutdown
222220 return Mono .whenDelayError (Mono .error (ex ), shutdown ()).cast (Microservices .class );
223221 })
224- .doOnSuccess (m -> listenJvmShutdown ())
225222 .doOnSuccess (m -> LOGGER .info ("[{}][start] Started" , id ))
226223 .doOnTerminate (scheduler ::dispose );
227224 }
@@ -291,12 +288,6 @@ public Mono<Void> onShutdown() {
291288 return onShutdown ;
292289 }
293290
294- private void listenJvmShutdown () {
295- SignalHandler handler = signal -> shutdown .onComplete ();
296- Signal .handle (new Signal ("TERM" ), handler );
297- Signal .handle (new Signal ("INT" ), handler );
298- }
299-
300291 private Mono <Void > doShutdown () {
301292 return Mono .defer (
302293 () -> {
You can’t perform that action at this time.
0 commit comments