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:24 UTC
[camel-kamelets] branch more-headers-support-9 created (now d2a978de)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch more-headers-support-9
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at d2a978de Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MongoDB
This branch includes the following new commits:
new 071ceeab Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Minio
new d2a978de Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MongoDB
The 2 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
[camel-kamelets] 02/02: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MongoDB
Posted by ac...@apache.org.
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());
}
}
[camel-kamelets] 01/02: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Minio
Posted by ac...@apache.org.
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 071ceeab31f29982d28a90692fa023e46b479e4f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 18:08:10 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Minio
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++-
.../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++
2 files changed, 6 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 82cec34c..fdae4ece 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
@@ -85,7 +85,8 @@ public enum KameletPrefixSchemeEnum {
kubernetes_pods("kubernetes-pods", "kubernetes-pods"),
log("log", "log"),
mail("mail", "imaps"),
- mariadb("mariadb", "sql");
+ mariadb("mariadb", "sql"),
+ minio("minio", "minio");
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 7355db88..65ad6119 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
@@ -270,5 +270,9 @@ public class KameletsCatalogTest {
assertEquals(0, headersMariaDBSource.size());
List<ComponentModel.EndpointHeaderModel> headersMariaDBSink= catalog.getKameletSupportedHeaders("mariadb-sink");
assertEquals(8, headersMariaDBSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersMinioSource= catalog.getKameletSupportedHeaders("minio-source");
+ assertEquals(14, headersMinioSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersMinioSink= catalog.getKameletSupportedHeaders("minio-sink");
+ assertEquals(21, headersMinioSink.size());
}
}