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
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(String socketPath, String socketPrefix, DataBroker dataBroker) {\r
SocketInfo socketInfo = new SocketInfo(socketPath, socketPrefix);\r
- neutronListener = new NeutronListener(dataBroker, socketInfo);\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