diff --git a/src/test/java/org/opencord/kafka/integrations/AccessDeviceKafkaIntegrationTest.java b/src/test/java/org/opencord/kafka/integrations/AccessDeviceKafkaIntegrationTest.java
index e158828..ce8244c 100644
--- a/src/test/java/org/opencord/kafka/integrations/AccessDeviceKafkaIntegrationTest.java
+++ b/src/test/java/org/opencord/kafka/integrations/AccessDeviceKafkaIntegrationTest.java
@@ -136,6 +136,11 @@
         }
 
         @Override
+        public ImmutableMap<ConnectPoint, Set<UniTagInformation>> getFailedSubs() {
+            return null;
+        }
+
+        @Override
         public void addListener(AccessDeviceListener listener) {
             accessDeviceListener = listener;
         }