Merge pull request #4 from dfbarreto/add-shared-channel-init

Added SharedTCP channel initializer

pom.xml

@@ -6,7 +6,7 @@
 
     <groupId>pt.unl.fct.di.novasys</groupId>
     <artifactId>babel-core</artifactId>
-    <version>0.5.02</version>
+    <version>0.5.03</version>
 
     <properties>
         <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>

src/main/java/pt/unl/fct/di/novasys/babel/core/Babel.java

@@ -15,6 +15,7 @@
 import pt.unl.fct.di.novasys.channel.accrual.AccrualChannel;
 import pt.unl.fct.di.novasys.channel.simpleclientserver.SimpleClientChannel;
 import pt.unl.fct.di.novasys.channel.simpleclientserver.SimpleServerChannel;
+import pt.unl.fct.di.novasys.channel.tcp.SharedTCPChannel;
 import pt.unl.fct.di.novasys.channel.tcp.TCPChannel;
 import pt.unl.fct.di.novasys.network.ISerializer;
 import pt.unl.fct.di.novasys.network.data.Host;
@@ -121,6 +122,7 @@ private Babel() {
         registerChannelInitializer(SimpleServerChannel.NAME, new SimpleServerChannelInitializer());
         registerChannelInitializer(TCPChannel.NAME, new TCPChannelInitializer());
         registerChannelInitializer(AccrualChannel.NAME, new AccrualChannelInitializer());
+        registerChannelInitializer(SharedTCPChannel.NAME, new SharedTCPChannelInitializer());
 
         //registerChannelInitializer("Ackos", new AckosChannelInitializer());
         //registerChannelInitializer(MultithreadedTCPChannel.NAME, new MultithreadedTCPChannelInitializer());

src/main/java/pt/unl/fct/di/novasys/babel/initializers/SharedTCPChannelInitializer.java

@@ -0,0 +1,18 @@
+package pt.unl.fct.di.novasys.babel.initializers;
+
+import pt.unl.fct.di.novasys.babel.internal.BabelMessage;
+import pt.unl.fct.di.novasys.channel.ChannelListener;
+import pt.unl.fct.di.novasys.channel.tcp.SharedTCPChannel;
+import pt.unl.fct.di.novasys.network.ISerializer;
+
+import java.io.IOException;
+import java.util.Properties;
+
+public class SharedTCPChannelInitializer implements ChannelInitializer<SharedTCPChannel<BabelMessage>> {
+
+    @Override
+    public SharedTCPChannel<BabelMessage> initialize(ISerializer<BabelMessage> iSerializer, ChannelListener<BabelMessage> channelListener,
+                                                     Properties properties, short protoId) throws IOException {
+        return new SharedTCPChannel<>(iSerializer, channelListener, properties);
+    }
+}