You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@camel.apache.org by ac...@apache.org on 2020/10/09 06:24:56 UTC
[camel-kafka-connector] 03/03: Catalog: expose an API for consuming
connectors catalog metadata and options, some little adjustments
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch issue-542
in repository https://gitbox.apache.org/repos/asf/camel-kafka-connector.git
commit 88edf1710e06e41496286948a4e20b3ff473aab8
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 9 08:21:38 2020 +0200
Catalog: expose an API for consuming connectors catalog metadata and options, some little adjustments
---
.../camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java | 8 ++++++--
1 file changed, 6 insertions(+), 2 deletions(-)
diff --git a/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java b/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java
index cb92dd5..77d5d4c 100644
--- a/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java
+++ b/camel-kafka-connector-catalog/src/main/java/org/apache/camel/kafkaconnector/catalog/CamelKafkaConnectorCatalog.java
@@ -17,6 +17,7 @@
package org.apache.camel.kafkaconnector.catalog;
import java.io.BufferedReader;
+import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.IOException;
@@ -42,6 +43,9 @@ public class CamelKafkaConnectorCatalog {
static List<String> connectorsName = new ArrayList<String>();
static Map<String, CamelKafkaConnectorModel> connectorsModel = new HashMap<String, CamelKafkaConnectorModel>();
private static final Logger LOG = LoggerFactory.getLogger(CamelKafkaConnectorCatalog.class);
+ private static final String CONNECTORS_DIR = "src/generated/resources/connectors";
+ private static final String DESCRIPTORS_DIR = "src/generated/resources/descriptors";
+ private static final String CONNECTORS_PROPERTIES = "connectors.properties";
public CamelKafkaConnectorCatalog() {
initCatalog();
@@ -55,7 +59,7 @@ public class CamelKafkaConnectorCatalog {
}
private void initCatalog() {
- try (FileInputStream input = new FileInputStream("src/generated/resources/descriptors/connectors.properties")) {
+ try (FileInputStream input = new FileInputStream(DESCRIPTORS_DIR + File.separator + CONNECTORS_PROPERTIES)) {
BufferedReader reader = new BufferedReader(new InputStreamReader(input));
@@ -83,7 +87,7 @@ public class CamelKafkaConnectorCatalog {
public String getConnectorAsJson(String connectorName) {
String result = null;
try {
- result = Files.lines(Paths.get("src/generated/resources/connectors/" + connectorName + ".json")).parallel() // for
+ result = Files.lines(Paths.get(CONNECTORS_DIR + File.separator + connectorName + ".json")).parallel() // for
// parallel
// processing
.map(String::trim) // to change line