refactoring

Anar-Framework · Jan 16, 2020 · 0681ede · 0681ede
1 parent 2564ea4
commit 0681ede
Show file tree

Hide file tree

Showing 5 changed files with 3 additions and 128 deletions.
diff --git a/src/main/java/af/gov/anar/connect/api/KafkaConnectApiResource.java b/src/main/java/af/gov/anar/connect/api/KafkaConnectApiResource.java
@@ -1,7 +1,7 @@
 package af.gov.anar.connect.api;
 
 
-import af.gov.anar.connect.core.KafkaConnectIntegrationService;
+import af.gov.anar.connect.service.KafkaConnectIntegrationService;
 import af.gov.anar.connect.util.Utility;
 import org.json.JSONObject;
 import org.sourcelab.kafka.connect.apiclient.request.dto.*;
@@ -17,7 +17,7 @@
 import java.util.Map;
 
 @RestController
-@RequestMapping(value = "/api/integrations")
+@RequestMapping(value = "/api/connect")
 public class KafkaConnectApiResource {
 
     @Autowired
@@ -83,7 +83,6 @@ ResponseEntity<ConnectorStatus> getConnectorStatus(@PathVariable(name = "name",
     ResponseEntity<Object> addConnector(@RequestBody(required = true) String connectorString)
     {
         JSONObject jsonConfig = utility.parse(connectorString);
-
         String connectorName = jsonConfig.getString("name");
         String connectorConfig =jsonConfig.getString("config");
 

diff --git a/src/main/java/af/gov/anar/connect/core/Topics.java b/src/main/java/af/gov/anar/connect/core/Topics.java
diff --git a/src/main/java/af/gov/anar/connect/core/init/InitBeans.java b/src/main/java/af/gov/anar/connect/core/init/InitBeans.java
diff --git a/src/main/java/af/gov/anar/connect/core/init/KafkaConnectorsInitiator.java b/src/main/java/af/gov/anar/connect/core/init/KafkaConnectorsInitiator.java
diff --git a/.../core/KafkaConnectIntegrationService.java → ...rvice/KafkaConnectIntegrationService.java b/.../core/KafkaConnectIntegrationService.java → ...rvice/KafkaConnectIntegrationService.java
@@ -1,4 +1,4 @@
-package af.gov.anar.connect.core;
+package af.gov.anar.connect.service;
 
 
 import af.gov.anar.connect.util.Utility;