From e4b4e7089dbac3bba46d1880ae61bd444931f3e9 Mon Sep 17 00:00:00 2001
From: harshit aggarwal <haaggarw@microsoft.com>
Date: Thu, 22 Oct 2020 10:36:58 -0400
Subject: [PATCH] Adding ITopicsRepository Interface
---
.../interfaces/subscriber/ITopicsRepository.java | 9 +++++++++
.../subscriber/persistence/TopicsRepository.java | 3 ++-
.../register/subscriber/services/AvailableTopics.java | 3 ++-
3 files changed, 13 insertions(+), 2 deletions(-)
create mode 100644 register-core/src/main/java/org/opengroup/osdu/register/provider/interfaces/subscriber/ITopicsRepository.java
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 000000000..e5ce3babf
--- /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 9cc756111..72f3f447a 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 06cee08a4..d30b8100a 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))
--
GitLab