commit 5e406d2b758f1a5e1aa26b68261a87ba3e85ce7b
author Matteo Scandolo <teo@opennetworking.org> Mon Aug 24 15:17:54 2020 -0700
committer Matteo Scandolo <teo@opennetworking.org> Mon Aug 24 15:17:54 2020 -0700
tree 0c0cfec3089519bbe0af2eeeee1c264201a01538
parent 91d31b3c8d21a79d6cd6f790a4452faf0da0e73e

[VOL-2778] Updating kafka dependency on dhcpl2relay 2.2.0-SNAPSHOT

Change-Id: Ie50d393c228f505874e193cb7f46efaeaf51da9e

src/test/java/org/opencord/kafka/integrations/DhcpL2RelayKafkaIntegrationTest.java

diff --git a/src/test/java/org/opencord/kafka/integrations/DhcpL2RelayKafkaIntegrationTest.java b/src/test/java/org/opencord/kafka/integrations/DhcpL2RelayKafkaIntegrationTest.java
index fe45d40..3a4ed77 100644
--- a/src/test/java/org/opencord/kafka/integrations/DhcpL2RelayKafkaIntegrationTest.java
+++ b/src/test/java/org/opencord/kafka/integrations/DhcpL2RelayKafkaIntegrationTest.java
@@ -68,7 +68,7 @@
         DhcpAllocationInfo allocationInfo = new DhcpAllocationInfo(
                 OLT_CONNECT_POINT,
                 DHCP.MsgType.DHCPREQUEST, ONU_SERIAL, OLT_MAC,
-                LOCAL_IP);
+                LOCAL_IP, SUBSCRIBER_ID);
         DhcpL2RelayEvent event = new DhcpL2RelayEvent(DhcpL2RelayEvent.Type.STATS_UPDATE,
                 allocationInfo, OLT_CONNECT_POINT, entryCounter, null);
         dhcpL2RelayListener.event(event);
@@ -86,7 +86,7 @@
         DhcpAllocationInfo allocationInfo = new DhcpAllocationInfo(
                 OLT_CONNECT_POINT,
                 DHCP.MsgType.DHCPREQUEST, ONU_SERIAL, OLT_MAC,
-                LOCAL_IP);
+                LOCAL_IP, SUBSCRIBER_ID);
         DhcpL2RelayEvent event = new DhcpL2RelayEvent(DhcpL2RelayEvent.Type.STATS_UPDATE,
                 allocationInfo, OLT_CONNECT_POINT, entryCounter, ONU_SERIAL);
         dhcpL2RelayListener.event(event);
@@ -104,7 +104,7 @@
         DhcpAllocationInfo allocationInfo = new DhcpAllocationInfo(
                 new ConnectPoint(DEVICE_ID_1, PORT.number()),
                 DHCP.MsgType.DHCPREQUEST, ONU_SERIAL, OLT_MAC,
-                LOCAL_IP);
+                LOCAL_IP, SUBSCRIBER_ID);
         DhcpL2RelayEvent event = new DhcpL2RelayEvent(DhcpL2RelayEvent.Type.UPDATED,
                 allocationInfo, cp, entryCounter, null);
         dhcpL2RelayListener.event(event);
@@ -161,7 +161,7 @@
         }
 
         @Override
-        public boolean removeAllocationByConnectPoint(ConnectPoint connectPoint) {
+        public boolean removeAllocationsByConnectPoint(ConnectPoint connectPoint) {
             return false;
         }
     }