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/17 08:55:32 UTC
[camel-kamelets] 05/06: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - FTP/FTPS
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch more-headers-support
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit d9c03773162089039ebdb7158d8913648e0a9a0b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Oct 17 10:43:58 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - FTP/FTPS
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 4 +++-
.../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 8 ++++++++
2 files changed, 11 insertions(+), 1 deletion(-)
diff --git a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java
index 0c3e5f60..d5b4c7b6 100644
--- a/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java
+++ b/library/camel-kamelets-catalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java
@@ -49,7 +49,9 @@ public enum KameletPrefixSchemeEnum {
elasticsearch_rest_search("elasticsearch-search", "elasticsearch-rest"),
exec("exec", "exec"),
fhir("fhir", "fhir"),
- file_watch("file-watch", "file-watch");
+ file_watch("file-watch", "file-watch"),
+ ftp("ftp", "ftp"),
+ ftps("ftps", "ftps");
public final String name;
public final String scheme;
diff --git a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
index ffb8aaf9..2073a25b 100644
--- a/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
+++ b/library/camel-kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
@@ -170,5 +170,13 @@ public class KameletsCatalogTest {
assertEquals(0, headersFhirSource.size());
List<ComponentModel.EndpointHeaderModel> headersFileWatchSource = catalog.getKameletSupportedHeaders("file-watch-source");
assertEquals(10, headersFileWatchSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersFtpSource = catalog.getKameletSupportedHeaders("ftp-source");
+ assertEquals(10, headersFtpSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersFtpSink = catalog.getKameletSupportedHeaders("ftp-sink");
+ assertEquals(8, headersFtpSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersFtpsSource = catalog.getKameletSupportedHeaders("ftps-source");
+ assertEquals(10, headersFtpsSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersFtpsSink = catalog.getKameletSupportedHeaders("ftps-sink");
+ assertEquals(8, headersFtpsSink.size());
}
}