commit bbb36598481910f77c08f5c987bec4ae10fad722
author Andrea Campanella <andrea@opennetworking.org> Wed Jul 01 16:50:48 2020 +0200
committer Andrea Campanella <andrea@opennetworking.org> Wed Jul 01 16:50:48 2020 +0200
tree 4939335f2911812bd4a63c6ed13e4486cd3364f8
parent 6f0eeafafb4d29ad964483c3ace841a41f59e6ee

Updating to released API version and test fixes

Change-Id: I2d4f54489b7208cc65df8c0b22a0586a9fb50a1b

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

diff --git a/src/test/java/org/opencord/kafka/integrations/KafkaIntegrationTestBase.java b/src/test/java/org/opencord/kafka/integrations/KafkaIntegrationTestBase.java
index e66e8e5..81fe499 100644
--- a/src/test/java/org/opencord/kafka/integrations/KafkaIntegrationTestBase.java
+++ b/src/test/java/org/opencord/kafka/integrations/KafkaIntegrationTestBase.java
@@ -131,9 +131,9 @@
     protected CordMcastStatisticsEvent getCordMcastStatisticsEvent() {
         List<CordMcastStatistics> statsList = Lists.newArrayList(
                 new CordMcastStatistics(IpAddress.valueOf("172.16.34.34"),
-                        "192.168.0.21", VlanId.vlanId("100")),
+                        "192.168.0.21", VlanId.vlanId("100"), VlanId.vlanId("200")),
                 new CordMcastStatistics(IpAddress.valueOf("172.16.35.35"),
-                        "192.168.0.22", VlanId.vlanId("101"))
+                        "192.168.0.22", VlanId.vlanId("101"), VlanId.vlanId("201"))
         );
         return new CordMcastStatisticsEvent(
                 CordMcastStatisticsEvent.Type.STATUS_UPDATE, statsList);