Merged and removed bytebuf-codec module to services/trasport-rscoket (#839)

Author: artem-v

pom.xml

@@ -86,7 +86,6 @@
     <module>services-api</module>
     <module>services-transport-parent</module>
     <module>services-discovery</module>
-    <module>services-bytebuf-codec</module>
     <module>services-security</module>
     <module>services-examples</module>
   </modules>

services-bytebuf-codec/pom.xml

@@ -6,7 +6,6 @@
 import io.scalecube.services.api.ServiceMessage;
 import io.scalecube.services.exceptions.ConnectionClosedException;
 import io.scalecube.services.transport.api.ClientChannel;
-import io.scalecube.services.transport.api.ServiceMessageCodec;
 import java.lang.reflect.Type;
 import org.reactivestreams.Publisher;
 import org.slf4j.Logger;

services-bytebuf-codec/src/main/resources/META-INF/services/io.scalecube.services.transport.api.ServiceMessageDataDecoder

@@ -18,8 +18,6 @@
 import io.scalecube.services.transport.api.ClientTransport;
 import io.scalecube.services.transport.api.DataCodec;
 import io.scalecube.services.transport.api.HeadersCodec;
-import io.scalecube.services.transport.api.ReferenceCountUtil;
-import io.scalecube.services.transport.api.ServiceMessageCodec;
 import io.scalecube.utils.MaskUtil;
 import java.util.Collection;
 import java.util.Collections;

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketClientChannel.java

@@ -20,8 +20,6 @@
 import io.scalecube.services.methods.ServiceMethodRegistry;
 import io.scalecube.services.transport.api.DataCodec;
 import io.scalecube.services.transport.api.HeadersCodec;
-import io.scalecube.services.transport.api.ReferenceCountUtil;
-import io.scalecube.services.transport.api.ServiceMessageCodec;
 import java.util.Collection;
 import org.reactivestreams.Publisher;
 import org.slf4j.Logger;

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketClientTransport.java

@@ -1,4 +1,4 @@
-package io.scalecube.services.transport.api;
+package io.scalecube.services.transport.rsocket;
 
 import io.netty.util.ReferenceCounted;
 import org.slf4j.Logger;

services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/RSocketServiceAcceptor.java

@@ -1,6 +1,7 @@
-package io.scalecube.services.transport.api;
+package io.scalecube.services.transport.rsocket;
 
 import io.scalecube.services.api.ServiceMessage;
+import io.scalecube.services.transport.api.ServiceMessageDataDecoder;
 
 public class ServiceMessageByteBufDataDecoder implements ServiceMessageDataDecoder {
 

services-bytebuf-codec/src/main/java/io/scalecube/services/transport/api/ReferenceCountUtil.java renamed to services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/ReferenceCountUtil.java

@@ -1,4 +1,4 @@
-package io.scalecube.services.transport.api;
+package io.scalecube.services.transport.rsocket;
 
 import static java.util.function.Function.identity;
 import static java.util.stream.Collectors.collectingAndThen;
@@ -12,6 +12,9 @@
 import io.scalecube.services.api.ErrorData;
 import io.scalecube.services.api.ServiceMessage;
 import io.scalecube.services.exceptions.MessageCodecException;
+import io.scalecube.services.transport.api.DataCodec;
+import io.scalecube.services.transport.api.HeadersCodec;
+import io.scalecube.services.transport.api.JdkCodec;
 import java.lang.reflect.Type;
 import java.util.Collection;
 import java.util.Collections;

services-bytebuf-codec/src/main/java/io/scalecube/services/transport/api/ServiceMessageByteBufDataDecoder.java renamed to services-transport-parent/services-transport-rsocket/src/main/java/io/scalecube/services/transport/rsocket/ServiceMessageByteBufDataDecoder.java

@@ -0,0 +1 @@
+io.scalecube.services.transport.rsocket.ServiceMessageByteBufDataDecoder