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/19 16:19:26 UTC
[camel-kamelets] 02/02: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MongoDB
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch more-headers-support-9
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit d2a978de54f0dad5c9ac029dd5e31dfe60190100
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 18:17:05 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MongoDB
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 4 +++-
.../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 6 ++++++
2 files changed, 9 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 fdae4ece..4562db9c 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
@@ -86,7 +86,9 @@ public enum KameletPrefixSchemeEnum {
log("log", "log"),
mail("mail", "imaps"),
mariadb("mariadb", "sql"),
- minio("minio", "minio");
+ minio("minio", "minio"),
+ mongodb_changes_stream("mongodb-changes-stream", "mongodb"),
+ mongodb("mongodb", "mongodb");
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 65ad6119..cb894480 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
@@ -274,5 +274,11 @@ public class KameletsCatalogTest {
assertEquals(14, headersMinioSource.size());
List<ComponentModel.EndpointHeaderModel> headersMinioSink= catalog.getKameletSupportedHeaders("minio-sink");
assertEquals(21, headersMinioSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersMongodbChangesStreamSource= catalog.getKameletSupportedHeaders("mongodb-changes-stream-source");
+ assertEquals(3, headersMongodbChangesStreamSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersMongoDbSink= catalog.getKameletSupportedHeaders("mongodb-sink");
+ assertEquals(12, headersMongoDbSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersMongoDbSource= catalog.getKameletSupportedHeaders("mongodb-source");
+ assertEquals(3, headersMongoDbSource.size());
}
}