diff --git a/register-core/src/main/java/org/opengroup/osdu/register/provider/interfaces/subscriber/ITopicsRepository.java b/register-core/src/main/java/org/opengroup/osdu/register/provider/interfaces/subscriber/ITopicsRepository.java
new file mode 100644
index 0000000000000000000000000000000000000000..e5ce3babfd629b68a94c92a20512cf7da8673d19
--- /dev/null
+++ b/register-core/src/main/java/org/opengroup/osdu/register/provider/interfaces/subscriber/ITopicsRepository.java
@@ -0,0 +1,9 @@
+package org.opengroup.osdu.register.provider.interfaces.subscriber;
+
+import org.opengroup.osdu.core.common.model.notification.Topic;
+
+import java.util.List;
+
+public interface ITopicsRepository {
+    List<Topic> listMessages();
+}
diff --git a/register-core/src/main/java/org/opengroup/osdu/register/subscriber/persistence/TopicsRepository.java b/register-core/src/main/java/org/opengroup/osdu/register/subscriber/persistence/TopicsRepository.java
index 9cc756111b3f5401303ef421f0588514782a8963..72f3f447a72769b18f231fcaca87083e17bd5b7f 100644
--- a/register-core/src/main/java/org/opengroup/osdu/register/subscriber/persistence/TopicsRepository.java
+++ b/register-core/src/main/java/org/opengroup/osdu/register/subscriber/persistence/TopicsRepository.java
@@ -22,6 +22,7 @@ import org.apache.http.HttpStatus;
 import org.opengroup.osdu.core.common.logging.JaxRsDpsLog;
 import org.opengroup.osdu.core.common.model.http.AppException;
 import org.opengroup.osdu.core.common.model.notification.Topic;
+import org.opengroup.osdu.register.provider.interfaces.subscriber.ITopicsRepository;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.core.io.ClassPathResource;
 import org.springframework.stereotype.Repository;
@@ -33,7 +34,7 @@ import java.util.ArrayList;
 import java.util.List;
 
 @Repository
-public class TopicsRepository {
+public class TopicsRepository implements ITopicsRepository {
 
     @Autowired
     private JaxRsDpsLog log;
diff --git a/register-core/src/main/java/org/opengroup/osdu/register/subscriber/services/AvailableTopics.java b/register-core/src/main/java/org/opengroup/osdu/register/subscriber/services/AvailableTopics.java
index 06cee08a4863bc0484d8b6605c5e043b9816c5c6..d30b8100affcae770d9ab9ea9f8513f3a7c87b01 100644
--- a/register-core/src/main/java/org/opengroup/osdu/register/subscriber/services/AvailableTopics.java
+++ b/register-core/src/main/java/org/opengroup/osdu/register/subscriber/services/AvailableTopics.java
@@ -18,6 +18,7 @@ package org.opengroup.osdu.register.subscriber.services;
 
 import com.google.common.base.Strings;
 import org.opengroup.osdu.core.common.model.notification.Topic;
+import org.opengroup.osdu.register.provider.interfaces.subscriber.ITopicsRepository;
 import org.opengroup.osdu.register.subscriber.persistence.TopicsRepository;
 import org.springframework.beans.factory.annotation.Autowired;
 import org.springframework.stereotype.Service;
@@ -29,7 +30,7 @@ import java.util.stream.Collectors;
 public class AvailableTopics {
 
     @Autowired
-    private TopicsRepository topicRepo;
+    private ITopicsRepository topicRepo;
 
     public boolean exists(String name) {
         if (Strings.isNullOrEmpty(name))