Merge pull request #341 from scalecube/update-commons

Update sc-commons

Author: artem-v

cluster/src/main/java/io/scalecube/cluster/membership/MembershipProtocolImpl.java

@@ -20,6 +20,7 @@
 import java.net.InetAddress;
 import java.nio.ByteBuffer;
 import java.nio.file.Path;
+import java.nio.file.Paths;
 import java.time.Duration;
 import java.util.ArrayList;
 import java.util.Arrays;
@@ -509,8 +510,8 @@ private Mono<Void> syncMembership(SyncData syncData, boolean onStart) {
   }
 
   private static boolean areNamespacesRelated(String namespace1, String namespace2) {
-    Path ns1 = Path.of(namespace1);
-    Path ns2 = Path.of(namespace2);
+    Path ns1 = Paths.get(namespace1);
+    Path ns2 = Paths.get(namespace2);
 
     if (ns1.compareTo(ns2) == 0) {
       return true;

pom.xml

@@ -7,7 +7,7 @@
   <parent>
     <groupId>io.scalecube</groupId>
     <artifactId>scalecube-parent-pom</artifactId>
-    <version>0.1.2-RC1</version>
+    <version>0.1.2-RC3</version>
   </parent>
   <packaging>pom</packaging>
 
@@ -21,7 +21,7 @@
   </scm>
 
   <properties>
-    <scalecube-commons.version>1.0.4</scalecube-commons.version>
+    <scalecube-commons.version>1.0.6</scalecube-commons.version>
     <slf4j.version>1.7.30</slf4j.version>
     <log4j.version>2.13.2</log4j.version>
     <reactor.version>Dysprosium-SR8</reactor.version>

transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/TransportImpl.java

@@ -133,11 +133,11 @@ public static Mono<Transport> bind() {
    * @return promise for bind operation
    */
   public static Mono<Transport> bind(TransportConfig config) {
-    TransportFactory transportFactory =
-        Optional.ofNullable(config.transportFactory())
-            .or(() -> Optional.ofNullable(TransportFactory.INSTANCE))
-            .orElse(new TcpTransportFactory());
-    return transportFactory.createTransport(config).start();
+    return Optional.ofNullable(
+            Optional.ofNullable(config.transportFactory()).orElse(TransportFactory.INSTANCE))
+        .orElse(new TcpTransportFactory())
+        .createTransport(config)
+        .start();
   }
 
   /**