Updated poms

artem-v · artem-v · commit f6b742534dfa · 2020-06-11T05:31:14.000+03:00
diff --git a/cluster-api/pom.xml b/cluster-api/pom.xml
@@ -5,7 +5,7 @@
   <parent>
     <groupId>io.scalecube</groupId>
     <artifactId>scalecube-cluster-parent</artifactId>
-    <version>2.5.1-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
   </parent>
 
   <artifactId>scalecube-cluster-api</artifactId>
diff --git a/cluster-testlib/pom.xml b/cluster-testlib/pom.xml
@@ -3,7 +3,7 @@
   <parent>
     <artifactId>scalecube-cluster-parent</artifactId>
     <groupId>io.scalecube</groupId>
-    <version>2.5.1-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/cluster/pom.xml b/cluster/pom.xml
@@ -5,7 +5,7 @@
   <parent>
     <groupId>io.scalecube</groupId>
     <artifactId>scalecube-cluster-parent</artifactId>
-    <version>2.5.1-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
   </parent>
 
   <artifactId>scalecube-cluster</artifactId>
diff --git a/codec-parent/codec-jackson-smile/pom.xml b/codec-parent/codec-jackson-smile/pom.xml
@@ -5,7 +5,7 @@
   <parent>
     <groupId>io.scalecube</groupId>
     <artifactId>scalecube-codec-parent</artifactId>
-    <version>2.5.1-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
   </parent>
 
   <artifactId>scalecube-codec-jackson-smile</artifactId>
diff --git a/codec-parent/codec-jackson/pom.xml b/codec-parent/codec-jackson/pom.xml
@@ -3,7 +3,7 @@
   <parent>
     <artifactId>scalecube-codec-parent</artifactId>
     <groupId>io.scalecube</groupId>
-    <version>2.5.1-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/codec-parent/pom.xml b/codec-parent/pom.xml
@@ -4,7 +4,7 @@
   <parent>
     <artifactId>scalecube-cluster-parent</artifactId>
     <groupId>io.scalecube</groupId>
-    <version>2.5.1-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
   <packaging>pom</packaging>
diff --git a/examples/pom.xml b/examples/pom.xml
@@ -4,7 +4,7 @@
   <parent>
     <groupId>io.scalecube</groupId>
     <artifactId>scalecube-cluster-parent</artifactId>
-    <version>2.5.1-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
   </parent>
 
   <artifactId>scalecube-cluster-examples</artifactId>
diff --git a/pom.xml b/pom.xml
@@ -3,7 +3,7 @@
   <modelVersion>4.0.0</modelVersion>
 
   <artifactId>scalecube-cluster-parent</artifactId>
-  <version>2.5.1-SNAPSHOT</version>
+  <version>2.6.0-SNAPSHOT</version>
   <parent>
     <groupId>io.scalecube</groupId>
     <artifactId>scalecube-parent-pom</artifactId>
diff --git a/transport-parent/pom.xml b/transport-parent/pom.xml
@@ -5,7 +5,7 @@
   <parent>
     <artifactId>scalecube-cluster-parent</artifactId>
     <groupId>io.scalecube</groupId>
-    <version>2.5.1-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
   </parent>
 
   <artifactId>scalecube-transport-parent</artifactId>
diff --git a/transport-parent/transport-api/pom.xml b/transport-parent/transport-api/pom.xml
@@ -3,7 +3,7 @@
   <parent>
     <artifactId>scalecube-transport-parent</artifactId>
     <groupId>io.scalecube</groupId>
-    <version>2.5.1-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
   </parent>
   <modelVersion>4.0.0</modelVersion>
 
diff --git a/transport-parent/transport-netty/pom.xml b/transport-parent/transport-netty/pom.xml
@@ -5,7 +5,7 @@
   <parent>
     <artifactId>scalecube-transport-parent</artifactId>
     <groupId>io.scalecube</groupId>
-    <version>2.5.1-SNAPSHOT</version>
+    <version>2.6.0-SNAPSHOT</version>
   </parent>
 
   <artifactId>scalecube-transport-netty</artifactId>
diff --git a/transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/TransportImpl.java b/transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/TransportImpl.java
@@ -38,15 +38,14 @@ public final class TransportImpl implements Transport {
 
   private static final Logger LOGGER = LoggerFactory.getLogger(Transport.class);
 
-  private final TransportConfig config;
   private final MessageCodec messageCodec;
 
   // Subject
   private final DirectProcessor<Message> subject = DirectProcessor.create();
   private final FluxSink<Message> sink = subject.sink();
 
   // Close handler
-  private final MonoProcessor<Void> stop = MonoProcessor.create();;
+  private final MonoProcessor<Void> stop = MonoProcessor.create();
   private final MonoProcessor<Void> onStop = MonoProcessor.create();
 
   // Server
@@ -62,13 +61,12 @@ public final class TransportImpl implements Transport {
   /**
    * Constructor with cofig as parameter.
    *
-   * @param config transport configuration
+   * @param messageCodec message codec
    * @param receiver transport receiver part
    * @param sender transport sender part
    */
-  public TransportImpl(TransportConfig config, Receiver receiver, Sender sender) {
-    this.config = config;
-    this.messageCodec = config.messageCodec();
+  public TransportImpl(MessageCodec messageCodec, Receiver receiver, Sender sender) {
+    this.messageCodec = messageCodec;
     this.receiver = receiver;
     this.sender = sender;
   }
diff --git a/transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/tcp/TcpTransportFactory.java b/transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/tcp/TcpTransportFactory.java
@@ -9,6 +9,6 @@ public final class TcpTransportFactory implements TransportFactory {
 
   @Override
   public Transport createTransport(TransportConfig config) {
-    return new TransportImpl(config, new TcpReceiver(config), new TcpSender(config));
+    return new TransportImpl(config.messageCodec(), new TcpReceiver(config), new TcpSender(config));
   }
 }
diff --git a/transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/websocket/WebsocketTransportFactory.java b/transport-parent/transport-netty/src/main/java/io/scalecube/transport/netty/websocket/WebsocketTransportFactory.java
@@ -9,6 +9,7 @@ public final class WebsocketTransportFactory implements TransportFactory {
 
   @Override
   public Transport createTransport(TransportConfig config) {
-    return new TransportImpl(config, new WebsocketReceiver(config), new WebsocketSender(config));
+    return new TransportImpl(
+        config.messageCodec(), new WebsocketReceiver(config), new WebsocketSender(config));
   }
 }
