Fixing socket for vpp endpoint

[groupbasedpolicy.git] / neutron-vpp-mapper / src / main / java / org / opendaylight / groupbasedpolicy / neutron / vpp / mapper / NeutronVppMapper.java

diff --git a/neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/NeutronVppMapper.java b/neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/NeutronVppMapper.java
index 70f859f42a5b543ee37e09f664601533bc3dbda2..861202f7407d35151bee484dc13485ce3b9c2f6c 100644 (file)
--- a/neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/NeutronVppMapper.java
+++ b/neutron-vpp-mapper/src/main/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/NeutronVppMapper.java
@@ -1,5 +1,5 @@
 /*\r
- * Copyright (c) 2014 Cisco Systems, Inc. and others. All rights reserved.\r
+ * Copyright (c) 2016 Cisco Systems, Inc. and others. All rights reserved.\r
  *\r
  * This program and the accompanying materials are made available under the\r
  * terms of the Eclipse Public License v1.0 which accompanies this distribution,\r
@@ -9,6 +9,7 @@
 package org.opendaylight.groupbasedpolicy.neutron.vpp.mapper;\r
 \r
 import org.opendaylight.controller.md.sal.binding.api.DataBroker;\r
+import org.opendaylight.groupbasedpolicy.neutron.vpp.mapper.hostconfigs.VppNodeListener;\r
 import org.opendaylight.groupbasedpolicy.neutron.vpp.mapper.processors.NeutronListener;\r
 import org.slf4j.Logger;\r
 import org.slf4j.LoggerFactory;\r
@@ -16,15 +17,19 @@ import org.slf4j.LoggerFactory;
 public class NeutronVppMapper implements AutoCloseable {\r
 \r
     NeutronListener neutronListener;\r
+    VppNodeListener vppNodeListener;\r
     private static final Logger LOG = LoggerFactory.getLogger(NeutronVppMapper.class);\r
 \r
-    public NeutronVppMapper(DataBroker dataBroker) {\r
+    public NeutronVppMapper(String socketPath, String socketPrefix, DataBroker dataBroker) {\r
+        SocketInfo socketInfo = new SocketInfo(socketPath, socketPrefix);\r
+        vppNodeListener = new VppNodeListener(dataBroker, socketInfo);\r
         neutronListener = new NeutronListener(dataBroker);\r
         LOG.info("Neutron VPP started!");\r
     }\r
 \r
     @Override\r
-    public void close() throws Exception {\r
+    public void close() {\r
         neutronListener.close();\r
+        vppNodeListener.close();\r
     }\r
 }\r