Merge pull request #720 from scalecube/update-dependencies

Updated dependencies

Author: segabriel

pom.xml

@@ -26,7 +26,7 @@
     <scalecube-cluster.version>2.4.10</scalecube-cluster.version>
     <scalecube-commons.version>1.0.2</scalecube-commons.version>
     <scalecube-benchmarks.version>1.2.2</scalecube-benchmarks.version>
-    <scalecube-config.version>0.3.11</scalecube-config.version>
+    <scalecube-config.version>0.4.3</scalecube-config.version>
     <reactor.version>Dysprosium-RELEASE</reactor.version>
     <rsocket.version>1.0.0-RC5</rsocket.version>
     <metrics.version>3.1.2</metrics.version>

services-examples-parent/services-examples-runner/src/main/java/io/scalecube/services/examples/ExamplesRunner.java

@@ -7,6 +7,7 @@
 import io.scalecube.config.source.SystemEnvironmentConfigSource;
 import io.scalecube.config.source.SystemPropertiesConfigSource;
 import io.scalecube.net.Address;
+import io.scalecube.runners.Runners;
 import io.scalecube.services.Microservices;
 import io.scalecube.services.ServiceEndpoint;
 import io.scalecube.services.discovery.ScalecubeServiceDiscovery;
@@ -51,29 +52,32 @@ public static void main(String[] args) {
             .orElse(Runtime.getRuntime().availableProcessors());
     LOGGER.info("Number of worker threads: " + numOfThreads);
 
-    Microservices.builder()
-        .discovery(endpoint -> serviceDiscovery(endpoint, config))
-        .transport(
-            () ->
-                new RSocketServiceTransport()
-                    .tcpClient(
-                        loopResources ->
-                            TcpClient.newConnection()
-                                .runOn(loopResources)
-                                .wiretap(false)
-                                .noProxy()
-                                .noSSL())
-                    .tcpServer(
-                        loopResources ->
-                            TcpServer.create()
-                                .wiretap(false)
-                                .port(config.servicePort())
-                                .runOn(loopResources)
-                                .noSSL()))
-        .services(new BenchmarkServiceImpl(), new GreetingServiceImpl())
-        .startAwait()
-        .onShutdown()
-        .block();
+    Microservices microservices =
+        Microservices.builder()
+            .discovery(endpoint -> serviceDiscovery(endpoint, config))
+            .transport(
+                () ->
+                    new RSocketServiceTransport()
+                        .tcpClient(
+                            loopResources ->
+                                TcpClient.newConnection()
+                                    .runOn(loopResources)
+                                    .wiretap(false)
+                                    .noProxy()
+                                    .noSSL())
+                        .tcpServer(
+                            loopResources ->
+                                TcpServer.create()
+                                    .wiretap(false)
+                                    .port(config.servicePort())
+                                    .runOn(loopResources)
+                                    .noSSL()))
+            .services(new BenchmarkServiceImpl(), new GreetingServiceImpl())
+            .startAwait();
+
+    Runners.onShutdown(() -> microservices.shutdown().subscribe());
+
+    microservices.onShutdown().block();
   }
 
   private static ServiceDiscovery serviceDiscovery(ServiceEndpoint endpoint, Config config) {