Fixing socket for vpp endpoint

[groupbasedpolicy.git] / neutron-vpp-mapper / src / test / java / org / opendaylight / groupbasedpolicy / neutron / vpp / mapper / processors / NeutronListenerTest.java

diff --git a/neutron-vpp-mapper/src/test/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/processors/NeutronListenerTest.java b/neutron-vpp-mapper/src/test/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/processors/NeutronListenerTest.java
index ee359c18d6b05a1e309f609b7ee1aac634c9be53..1ed99947e658506df20d745b1b12e4f1d35d0822 100644 (file)
--- a/neutron-vpp-mapper/src/test/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/processors/NeutronListenerTest.java
+++ b/neutron-vpp-mapper/src/test/java/org/opendaylight/groupbasedpolicy/neutron/vpp/mapper/processors/NeutronListenerTest.java
@@ -40,25 +40,24 @@ public class NeutronListenerTest extends AbstractDataBrokerTest {
     private Port port;\r
     private BaseEndpointByPort bebp;\r
     private NeutronListener neutronListener;\r
-    private BaseEndpointByPortListener baseEpByPortListener;\r
+    private PortAware baseEpByPortListener;\r
 \r
     @Before\r
     public void init() {\r
         port = TestUtils.createValidVppPort();\r
         bebp = TestUtils.createBaseEndpointByPortForPort();\r
-        socketInfo = new SocketInfo("/tmp/", "_socket");\r
         dataBroker = getDataBroker();\r
-        neutronListener = new NeutronListener(dataBroker, socketInfo);\r
+        neutronListener = new NeutronListener(dataBroker);\r
         neutronListener.clearDataChangeProviders();\r
-        baseEpByPortListener = Mockito.spy(new BaseEndpointByPortListener(new PortHandler(\r
-                dataBroker, socketInfo), dataBroker));\r
+        baseEpByPortListener = Mockito.spy(new PortAware(new PortHandler(\r
+                dataBroker), dataBroker));\r
         neutronListener.addDataChangeProvider(baseEpByPortListener);\r
     }\r
 \r
     @Test\r
     public void constructorTest() {\r
         dataBroker = Mockito.spy(dataBroker);\r
-        NeutronListener neutronListener = new NeutronListener(dataBroker, socketInfo);\r
+        NeutronListener neutronListener = new NeutronListener(dataBroker);\r
         verify(dataBroker).registerDataTreeChangeListener(\r
                 eq(new DataTreeIdentifier<>(LogicalDatastoreType.CONFIGURATION,\r
                         InstanceIdentifier.builder(Neutron.class)\r
@@ -69,7 +68,7 @@ public class NeutronListenerTest extends AbstractDataBrokerTest {
                         .child(GbpByNeutronMappings.class)\r
                         .child(BaseEndpointsByPorts.class)\r
                         .child(BaseEndpointByPort.class)\r
-                        .build())), any(BaseEndpointByPortListener.class));\r
+                        .build())), any(PortAware.class));\r
         neutronListener.close();\r
     }\r
 \r