X-Git-Url: https://git.opendaylight.org/gerrit/gitweb?a=blobdiff_plain;f=openflow-protocol-impl%2Fsrc%2Fmain%2Fjava%2Forg%2Fopendaylight%2Fopenflowjava%2Fprotocol%2Fimpl%2Fcore%2FChannelInitializerFactory.java;h=414f2c25f4676b93a23a1d00c5c59972d535c95c;hb=8910e62151c4a5b6285c38bf398b5a479b939fe2;hp=042d464081b28b05c2896d0167f204f4bb3c575f;hpb=7d2311dd81ec104024944110b3d682cc5a63d1e8;p=openflowjava.git

diff --git a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/ChannelInitializerFactory.java b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/ChannelInitializerFactory.java
index 042d4640..414f2c25 100644
--- a/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/ChannelInitializerFactory.java
+++ b/openflow-protocol-impl/src/main/java/org/opendaylight/openflowjava/protocol/impl/core/ChannelInitializerFactory.java
@@ -24,17 +24,19 @@ public class ChannelInitializerFactory {
     private SerializationFactory serializationFactory;
     private TlsConfiguration tlsConfig;
     private SwitchConnectionHandler switchConnectionHandler;
+    private boolean useBarrier;
 
     /**
      * @return PublishingChannelInitializer that initializes new channels
      */
     public TcpChannelInitializer createPublishingChannelInitializer() {
-        TcpChannelInitializer initializer = new TcpChannelInitializer();
+        final TcpChannelInitializer initializer = new TcpChannelInitializer();
         initializer.setSwitchIdleTimeout(switchIdleTimeOut);
         initializer.setDeserializationFactory(deserializationFactory);
         initializer.setSerializationFactory(serializationFactory);
         initializer.setTlsConfiguration(tlsConfig);
         initializer.setSwitchConnectionHandler(switchConnectionHandler);
+        initializer.setUseBarrier(useBarrier);
         return initializer;
     }
 
@@ -42,7 +44,7 @@ public class ChannelInitializerFactory {
      * @return PublishingChannelInitializer that initializes new channels
      */
     public UdpChannelInitializer createUdpChannelInitializer() {
-        UdpChannelInitializer initializer = new UdpChannelInitializer();
+        final UdpChannelInitializer initializer = new UdpChannelInitializer();
         initializer.setSwitchIdleTimeout(switchIdleTimeOut);
         initializer.setDeserializationFactory(deserializationFactory);
         initializer.setSerializationFactory(serializationFactory);
@@ -53,35 +55,42 @@ public class ChannelInitializerFactory {
     /**
      * @param switchIdleTimeOut
      */
-    public void setSwitchIdleTimeout(long switchIdleTimeOut) {
+    public void setSwitchIdleTimeout(final long switchIdleTimeOut) {
         this.switchIdleTimeOut = switchIdleTimeOut;
     }
 
     /**
      * @param deserializationFactory
      */
-    public void setDeserializationFactory(DeserializationFactory deserializationFactory) {
+    public void setDeserializationFactory(final DeserializationFactory deserializationFactory) {
         this.deserializationFactory = deserializationFactory;
     }
 
     /**
      * @param serializationFactory
      */
-    public void setSerializationFactory(SerializationFactory serializationFactory) {
+    public void setSerializationFactory(final SerializationFactory serializationFactory) {
         this.serializationFactory = serializationFactory;
     }
 
     /**
      * @param tlsConfig
      */
-    public void setTlsConfig(TlsConfiguration tlsConfig) {
+    public void setTlsConfig(final TlsConfiguration tlsConfig) {
         this.tlsConfig = tlsConfig;
     }
 
     /**
      * @param switchConnectionHandler
      */
-    public void setSwitchConnectionHandler(SwitchConnectionHandler switchConnectionHandler) {
+    public void setSwitchConnectionHandler(final SwitchConnectionHandler switchConnectionHandler) {
         this.switchConnectionHandler = switchConnectionHandler;
     }
+
+    /**
+     * @param useBarrier
+     */
+    public void setUseBarrier(final boolean useBarrier) {
+        this.useBarrier = useBarrier;
+    }
 }
\ No newline at end of file