gistify730965.java

diff --git a/ftest/pom.xml b/ftest/pom.xml
index 0161fd7..ae5a16d 100644
--- a/ftest/pom.xml
+++ b/ftest/pom.xml
@@ -28,6 +28,8 @@
               org.opendaylight.controller.sal.authorization,
               org.opendaylight.controller.sal.core,
               org.opendaylight.controller.sal.utils,
+              org.opendaylight.controller.sal.connection,
+              org.opendaylight.controller.connectionmanager,
               javax.annotation,
               javax.naming,
               javax.servlet,
@@ -104,6 +106,14 @@
       <artifactId>sal</artifactId>
     </dependency>
     <dependency>
+      <groupId>org.opendaylight.controller</groupId>
+      <artifactId>sal.connection</artifactId>
+    </dependency>
+    <dependency>
+      <groupId>org.opendaylight.controller</groupId>
+      <artifactId>connectionmanager</artifactId>
+    </dependency>
+    <dependency>
       <groupId>org.springframework</groupId>
       <artifactId>spring-web</artifactId>
     </dependency>
diff --git a/ftest/src/main/java/org/odl/ftest/internal/Simple.java b/ftest/src/main/java/org/odl/ftest/internal/Simple.java
index 8895b46..011cd04 100644
--- a/ftest/src/main/java/org/odl/ftest/internal/Simple.java
+++ b/ftest/src/main/java/org/odl/ftest/internal/Simple.java
@@ -3,14 +3,18 @@ package org.odl.ftest.internal;
 
 import org.odl.ftest.ISimple;
 import org.odl.ftest.SimpleData;
-
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
 import java.util.concurrent.ConcurrentHashMap;
+import java.util.HashMap;
 import java.util.UUID;
 import java.util.Map;
 
+import org.opendaylight.controller.connectionmanager.IConnectionManager;
+import org.opendaylight.controller.northbound.commons.exception.NotAcceptableException;
+import org.opendaylight.controller.sal.connection.ConnectionConstants;
+import org.opendaylight.controller.sal.utils.ServiceHelper;
 import org.opendaylight.controller.sal.utils.Status;
 import org.opendaylight.controller.sal.utils.StatusCode;
 
@@ -22,6 +26,18 @@ public class Simple implements ISimple {
         UUID uuid = UUID.randomUUID();
         SimpleData sData = new SimpleData(uuid.toString(), datum.getFoo(), datum.getBar());
         data.put(uuid, sData);
+        IConnectionManager conMgr = (IConnectionManager) ServiceHelper.getGlobalInstance(IConnectionManager.class, this);
+        try {
+            Integer.parseInt(datum.getBar());
+        } catch (Exception e) {
+            throw new NotAcceptableException("Invalid Layer4 Port "+datum.getBar());
+        }
+
+        Map<ConnectionConstants, String> params = new HashMap<ConnectionConstants, String>();
+        params.put(ConnectionConstants.ADDRESS, datum.getFoo());
+        params.put(ConnectionConstants.PORT, datum.getBar());
+        conMgr.connect(uuid.toString(), params);
+
         return uuid;
     }
     @Override