[VOL-4246] Adapting internal OLT API to new version
Change-Id: I8e155afb3f100301913f087a12f2fbf62c7e0c5f
diff --git a/src/test/java/org/opencord/kafka/integrations/AccessDeviceKafkaIntegrationTest.java b/src/test/java/org/opencord/kafka/integrations/AccessDeviceKafkaIntegrationTest.java
index ce8244c..254ba61 100644
--- a/src/test/java/org/opencord/kafka/integrations/AccessDeviceKafkaIntegrationTest.java
+++ b/src/test/java/org/opencord/kafka/integrations/AccessDeviceKafkaIntegrationTest.java
@@ -17,7 +17,6 @@
package org.opencord.kafka.integrations;
import com.fasterxml.jackson.databind.JsonNode;
-import com.google.common.collect.ImmutableMap;
import org.junit.jupiter.api.AfterEach;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
@@ -27,12 +26,8 @@
import org.opencord.kafka.EventBusService;
import org.opencord.olt.AccessDeviceListener;
import org.opencord.olt.AccessDeviceService;
-import org.opencord.olt.AccessSubscriberId;
-import org.opencord.sadis.UniTagInformation;
import java.util.List;
-import java.util.Optional;
-import java.util.Set;
import static org.junit.Assert.assertEquals;
@@ -112,31 +107,26 @@
}
@Override
- public boolean provisionSubscriber(AccessSubscriberId accessSubscriberId,
- Optional<VlanId> optional, Optional<VlanId> optional1,
- Optional<Integer> optional2) {
+ public boolean provisionSubscriber(ConnectPoint accessSubscriberId,
+ VlanId optional, VlanId optional1,
+ Integer optional2) {
return false;
}
@Override
- public boolean removeSubscriber(AccessSubscriberId accessSubscriberId,
- Optional<VlanId> optional, Optional<VlanId> optional1,
- Optional<Integer> optional2) {
+ public boolean removeSubscriber(ConnectPoint accessSubscriberId,
+ VlanId optional, VlanId optional1,
+ Integer optional2) {
return false;
}
@Override
- public List<DeviceId> fetchOlts() {
+ public List<DeviceId> getConnectedOlts() {
return null;
}
@Override
- public ImmutableMap<ConnectPoint, Set<UniTagInformation>> getProgSubs() {
- return null;
- }
-
- @Override
- public ImmutableMap<ConnectPoint, Set<UniTagInformation>> getFailedSubs() {
+ public ConnectPoint findSubscriberConnectPoint(String id) {
return null;
}