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 2022/10/21 08:47:22 UTC
[camel-kamelets] 01/03: Added a getKameletScheme method
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch kamelet-scheme-method
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit df94839ce9b15fd1aafa6439a36058debdb7213f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 21 10:41:51 2022 +0200
Added a getKameletScheme method
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../camel/kamelets/catalog/KameletsCatalog.java | 22 +++++++++++++++++-----
1 file changed, 17 insertions(+), 5 deletions(-)
diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java
index 0797c68a..31a688ec 100644
--- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java
+++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/KameletsCatalog.java
@@ -18,7 +18,13 @@ package org.apache.camel.kamelets.catalog;
import java.io.IOException;
import java.io.InputStream;
-import java.util.*;
+import java.util.ArrayList;
+import java.util.Collections;
+import java.util.Comparator;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.TreeMap;
import java.util.stream.Collectors;
import com.fasterxml.jackson.databind.DeserializationFeature;
@@ -193,10 +199,12 @@ public class KameletsCatalog {
String prefixName = local.getMetadata().getName().substring(0, lastIndex);
String schemeName = enumValue(prefixName);
if (schemeName != null) {
- List<ComponentModel.EndpointHeaderModel> headers = cc.componentModel(schemeName).getEndpointHeaders();
- for (ComponentModel.EndpointHeaderModel e : headers) {
- if (ObjectHelper.isEmpty(e.getLabel()) || e.getLabel().equalsIgnoreCase(camelType)) {
- resultingHeaders.add(e);
+ if (ObjectHelper.isNotEmpty(cc.componentModel(schemeName).getEndpointHeaders())) {
+ List<ComponentModel.EndpointHeaderModel> headers = cc.componentModel(schemeName).getEndpointHeaders();
+ for (ComponentModel.EndpointHeaderModel e : headers) {
+ if (ObjectHelper.isEmpty(e.getLabel()) || e.getLabel().equalsIgnoreCase(camelType)) {
+ resultingHeaders.add(e);
+ }
}
}
}
@@ -204,6 +212,10 @@ public class KameletsCatalog {
return resultingHeaders;
}
+ public String getKameletScheme(String prefix) {
+ return enumValue(prefix);
+ }
+
private String enumValue(String prefix) {
for (KameletPrefixSchemeEnum c : KameletPrefixSchemeEnum.values()) {
if (c.name.equals(prefix)) return c.scheme;