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:37:43 UTC

[camel-kamelets] branch main updated (eba4773e -> c570282f)

This is an automated email from the ASF dual-hosted git repository.

acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git


    from eba4773e Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SQL
     new f59ff06f Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Minio
     new c570282f 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.


Summary of changes:
 .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java  |  5 ++++-
 .../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 10 ++++++++++
 2 files changed, 14 insertions(+), 1 deletion(-)


[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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit c570282f43676558ed86aa148e1e24646a85166e
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 main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git

commit f59ff06f2d8a42ab522ce885e2fee6b8ed51dcde
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());
     }
 }