ISSUE-708 merge with develop

Author: Eugene_Utkin

services-api/src/test/java/io/scalecube/services/transport/api/JdkCodecTest.java

@@ -5,7 +5,9 @@
 import java.io.ByteArrayInputStream;
 import java.io.ByteArrayOutputStream;
 import java.io.IOException;
+import java.io.Serializable;
 import java.util.Arrays;
+import java.util.Objects;
 import java.util.stream.Stream;
 import org.junit.jupiter.params.ParameterizedTest;
 import org.junit.jupiter.params.provider.MethodSource;
@@ -22,7 +24,7 @@ void test(Object body) throws IOException {
   }
 
   static Stream<Object> provider() {
-    return Stream.of("hello", Arrays.<Object>asList(1,2,3));
+    return Stream.of("hello", Arrays.<Object>asList(1, 2, 3), new Greeting("joe"));
   }
 
   private Object writeAndRead(Object body) throws IOException {
@@ -34,4 +36,35 @@ private Object writeAndRead(Object body) throws IOException {
       }
     }
   }
-}
+
+  static class Greeting implements Serializable {
+
+    private final String name;
+
+    Greeting(String name) {
+      this.name = name;
+    }
+
+    public String getName() {
+      return name;
+    }
+
+    @Override
+    public boolean equals(Object o) {
+      if (this == o) {
+        return true;
+      }
+      if (o == null || getClass() != o.getClass()) {
+        return false;
+      }
+      Greeting greeting = (Greeting) o;
+      return Objects.equals(name, greeting.name);
+    }
+
+    @Override
+    public int hashCode() {
+      return Objects.hash(name);
+    }
+  }
+
+}

services-examples-parent/services-examples/src/main/java/io/scalecube/services/examples/codecs/Example2.java

@@ -0,0 +1,53 @@
+package io.scalecube.services.examples.codecs;
+
+import io.scalecube.net.Address;
+import io.scalecube.services.Microservices;
+import io.scalecube.services.discovery.ScalecubeServiceDiscovery;
+import io.scalecube.services.examples.helloworld.service.GreetingServiceImpl;
+import io.scalecube.services.examples.helloworld.service.api.GreetingsService;
+import io.scalecube.services.transport.rsocket.RSocketServiceTransport;
+
+public class Example2 {
+
+  public static final String CONTENT_TYPE = "application/octet-stream";
+
+  /**
+   * Start the example.
+   *
+   * @param args ignored
+   */
+  public static void main(String[] args) {
+    // ScaleCube Node node with no members
+    Microservices seed =
+        Microservices.builder()
+            .discovery(ScalecubeServiceDiscovery::new)
+            .transport(RSocketServiceTransport::new)
+            .contentType(CONTENT_TYPE) // need to send with non-default data format
+            .startAwait();
+
+    final Address seedAddress = seed.discovery().address();
+
+    // Construct a ScaleCube node which joins the cluster hosting the Greeting Service
+    Microservices ms =
+        Microservices.builder()
+            .discovery(
+                endpoint ->
+                    new ScalecubeServiceDiscovery(endpoint)
+                        .membership(cfg -> cfg.seedMembers(seedAddress)))
+            .transport(RSocketServiceTransport::new)
+            .services(new GreetingServiceImpl())
+            .startAwait();
+
+    // Create service proxy
+    GreetingsService service = seed.call().api(GreetingsService.class);
+
+    // Execute the services and subscribe to service events
+    service
+        .sayHello("joe")
+        .subscribe(consumer -> System.out.println(consumer.message()));
+
+    seed.onShutdown().block();
+    ms.onShutdown().block();
+  }
+
+}

services-examples-parent/services-examples/src/main/java/io/scalecube/services/examples/helloworld/service/api/Greeting.java

@@ -1,6 +1,8 @@
 package io.scalecube.services.examples.helloworld.service.api;
 
-public class Greeting {
+import java.io.Serializable;
+
+public class Greeting implements Serializable {
 
   String message;