/*\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
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
- private String socketPath;\r
-\r
- private String socketPrefix;\r
-\r
- public String getSocketPath() {\r
- return socketPath;\r
- }\r
-\r
- public void setSocketPath(String socketPath) {\r
- this.socketPath = socketPath;\r
- }\r
-\r
- public String getSocketPrefix() {\r
- return socketPrefix;\r
- }\r
-\r
- public void setSocketPrefix(String socketPrefix) {\r
- this.socketPrefix = socketPrefix;\r
- }\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