SEBA-986-CordMcastStatisticsService should use distributed storage infrastructure of ONOS
Change-Id: I3e22f3bde896f5a14b85fad88e5f84e58d3840a0
diff --git a/app/src/test/java/org/opencord/cordmcast/impl/McastTestBase.java b/app/src/test/java/org/opencord/cordmcast/impl/McastTestBase.java
index 9271976..758be58 100644
--- a/app/src/test/java/org/opencord/cordmcast/impl/McastTestBase.java
+++ b/app/src/test/java/org/opencord/cordmcast/impl/McastTestBase.java
@@ -28,6 +28,8 @@
import org.onlab.packet.IpAddress;
import org.onlab.packet.VlanId;
import org.onosproject.TestApplicationId;
+import org.onosproject.cluster.LeadershipServiceAdapter;
+import org.onosproject.cluster.NodeId;
import org.onosproject.core.ApplicationId;
import org.onosproject.core.CoreServiceAdapter;
import org.onosproject.event.DefaultEventSinkRegistry;
@@ -151,6 +153,13 @@
}
}
+ class LeadershipServiceMcastAdapter extends LeadershipServiceAdapter {
+ @Override
+ public NodeId getLeader(String path) {
+ return NodeId.nodeId("local");
+ }
+ }
+
protected class MockSadisService implements SadisService {
@Override