Fixed cycley dependency

Author: artem-v

codec-parent/codec-jdk/src/main/java/io/scalecube/cluster/codec/jdk/JdkMetadataCodec.java renamed to cluster-api/src/main/java/io/scalecube/cluster/metadata/DefaultMetadataCodec.java

@@ -1,14 +1,13 @@
-package io.scalecube.cluster.codec.jdk;
+package io.scalecube.cluster.metadata;
 
-import io.scalecube.cluster.metadata.MetadataCodec;
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.ObjectInputStream;
 import java.io.ObjectOutputStream;
 import java.nio.ByteBuffer;
 import reactor.core.Exceptions;
 
-public class JdkMetadataCodec implements MetadataCodec {
+public class DefaultMetadataCodec implements MetadataCodec {
 
   @Override
   public Object deserialize(ByteBuffer buffer) {

cluster-api/src/main/java/io/scalecube/cluster/metadata/MetadataCodec.java

@@ -1,14 +1,13 @@
 package io.scalecube.cluster.metadata;
 
-import io.scalecube.cluster.codec.jdk.JdkMetadataCodec;
 import io.scalecube.utils.ServiceLoaderUtil;
 import java.nio.ByteBuffer;
 
 /** Contains methods for metadata serializing/deserializing logic. */
 public interface MetadataCodec {
 
   MetadataCodec INSTANCE =
-      ServiceLoaderUtil.findFirst(MetadataCodec.class).orElseGet(JdkMetadataCodec::new);
+      ServiceLoaderUtil.findFirst(MetadataCodec.class).orElseGet(DefaultMetadataCodec::new);
 
   /**
    * Deserializes metadata from buffer.

cluster/src/main/java/io/scalecube/cluster/ClusterImpl.java

@@ -227,7 +227,7 @@ public Cluster startAwait() {
   }
 
   private Mono<Cluster> doStart() {
-    return Mono.fromRunnable(this::validateConfiguration).then(Mono.fromRunnable(this::doStart0));
+    return Mono.fromRunnable(this::validateConfiguration).then(Mono.defer(this::doStart0));
   }
 
   private Mono<Cluster> doStart0() {

codec-parent/codec-jdk/pom.xml

@@ -14,7 +14,6 @@
   <name>ScaleCube/ClusterCodec</name>
 
   <modules>
-    <module>codec-jdk</module>
     <module>codec-jackson</module>
   </modules>
 

codec-parent/pom.xml

@@ -18,12 +18,6 @@
   </modules>
 
   <dependencies>
-    <dependency>
-      <groupId>io.scalecube</groupId>
-      <artifactId>scalecube-codec-jdk</artifactId>
-      <version>${project.version}</version>
-    </dependency>
-
     <dependency>
       <groupId>io.projectreactor</groupId>
       <artifactId>reactor-core</artifactId>

transport-parent/pom.xml

@@ -1,14 +1,12 @@
-package io.scalecube.cluster.codec.jdk;
+package io.scalecube.cluster.transport.api;
 
-import io.scalecube.cluster.transport.api.Message;
-import io.scalecube.cluster.transport.api.MessageCodec;
 import java.io.IOException;
 import java.io.InputStream;
 import java.io.ObjectInputStream;
 import java.io.ObjectOutputStream;
 import java.io.OutputStream;
 
-public class JdkMessageCodec implements MessageCodec {
+public class DefaultMessageCodec implements MessageCodec {
 
   @Override
   public Message deserialize(InputStream is) throws IOException, ClassNotFoundException {

codec-parent/codec-jdk/src/main/java/io/scalecube/cluster/codec/jdk/JdkMessageCodec.java renamed to transport-parent/transport-api/src/main/java/io/scalecube/cluster/transport/api/DefaultMessageCodec.java

@@ -1,6 +1,5 @@
 package io.scalecube.cluster.transport.api;
 
-import io.scalecube.cluster.codec.jdk.JdkMessageCodec;
 import io.scalecube.utils.ServiceLoaderUtil;
 import java.io.InputStream;
 import java.io.OutputStream;
@@ -9,7 +8,7 @@
 public interface MessageCodec {
 
   MessageCodec INSTANCE =
-      ServiceLoaderUtil.findFirst(MessageCodec.class).orElseGet(JdkMessageCodec::new);
+      ServiceLoaderUtil.findFirst(MessageCodec.class).orElseGet(DefaultMessageCodec::new);
 
   /**
    * Deserializes message from given input stream.