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 09:17:50 UTC
[camel-kamelets] branch main updated (79adbcd8 -> eba4773e)
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 79adbcd8 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Infinispan
new cfc5c68c Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JIRA
new 18d6d7e3 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JIRA
new 9df3d20a Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS AMQP
new 365ae37f Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS ActiveMQ
new 014e04de Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS Artemis
new aabfc3df Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS IBM MQ
new a967ae6b Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Kafka
new 2aef3680 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Kubernetes
new 4624f67c Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Log
new 0b252757 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Mail
new eba4773e Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SQL
The 11 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:
.../catalog/model/KameletPrefixSchemeEnum.java | 21 ++++++++-
.../kamelets/catalog/KameletsCatalogTest.java | 52 ++++++++++++++++++++++
2 files changed, 72 insertions(+), 1 deletion(-)
[camel-kamelets] 03/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS AMQP
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 9df3d20af0427395285ed7282e28cf91c64dab86
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 10:31:35 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS AMQP
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 015cd08e..ce85b707 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
@@ -72,7 +72,8 @@ public enum KameletPrefixSchemeEnum {
jira_oauth("jira-oauth", "jira"),
jira("jira", "jira"),
jira_transition_issue("jira-transition-issue", "jira"),
- jira_update_issue("jira-update-issue", "jira");
+ jira_update_issue("jira-update-issue", "jira"),
+ jms_amqp_10("jms-amqp-10", "jms");
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 6818d1b0..d685280c 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
@@ -226,5 +226,9 @@ public class KameletsCatalogTest {
assertEquals(3, headersJiraSource.size());
List<ComponentModel.EndpointHeaderModel> headersJiraOauthSource= catalog.getKameletSupportedHeaders("jira-oauth-source");
assertEquals(3, headersJiraOauthSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersJmsAmqp10Source= catalog.getKameletSupportedHeaders("jms-amqp-10-source");
+ assertEquals(14, headersJmsAmqp10Source.size());
+ List<ComponentModel.EndpointHeaderModel> headersJmsAmqp10Sink= catalog.getKameletSupportedHeaders("jms-amqp-10-sink");
+ assertEquals(17, headersJmsAmqp10Sink.size());
}
}
[camel-kamelets] 01/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JIRA
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 cfc5c68c25dd24eabfed6f4022373276c03e44c8
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 10:25:22 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JIRA
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 8 +++++++-
.../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++
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 07c9bbd3..015cd08e 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
@@ -66,7 +66,13 @@ public enum KameletPrefixSchemeEnum {
google_storage("google-storage", "google-storage"),
http("http", "http"),
http_secured("http-secured", "http"),
- infinispan("infinispan", "infinispan");
+ infinispan("infinispan", "infinispan"),
+ jira_add_comment("jira-add-comment", "jira"),
+ jira_add_issue("jira-add-issue", "jira"),
+ jira_oauth("jira-oauth", "jira"),
+ jira("jira", "jira"),
+ jira_transition_issue("jira-transition-issue", "jira"),
+ jira_update_issue("jira-update-issue", "jira");
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 7dd4f590..19b10333 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
@@ -218,5 +218,9 @@ public class KameletsCatalogTest {
assertEquals(6, headersInfinispanSource.size());
List<ComponentModel.EndpointHeaderModel> headersInfinispanSink = catalog.getKameletSupportedHeaders("infinispan-sink");
assertEquals(14, headersInfinispanSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersJiraAddCommentSink = catalog.getKameletSupportedHeaders("jira-add-comment-sink");
+ assertEquals(16, headersJiraAddCommentSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersJiraAddIssueSink = catalog.getKameletSupportedHeaders("jira-add-issue-sink");
+ assertEquals(16, headersJiraAddIssueSink.size());
}
}
[camel-kamelets] 05/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS Artemis
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 014e04de49d4cdd8b239d9ced9fcb0b5f8140bc6
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 10:42:08 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS Artemis
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 422f7e5b..23d80512 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
@@ -74,7 +74,8 @@ public enum KameletPrefixSchemeEnum {
jira_transition_issue("jira-transition-issue", "jira"),
jira_update_issue("jira-update-issue", "jira"),
jms_amqp_10("jms-amqp-10", "jms"),
- jms_apache_activemq("jms-apache-activemq", "activemq");
+ jms_apache_activemq("jms-apache-activemq", "activemq"),
+ jms_apache_artemis("jms-apache-artemis", "jms");
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 f881636d..a11c894b 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
@@ -234,5 +234,9 @@ public class KameletsCatalogTest {
assertEquals(0, headersActivemqSource.size());
List<ComponentModel.EndpointHeaderModel> headersActivemqSink= catalog.getKameletSupportedHeaders("jms-apache-activemq-sink");
assertEquals(0, headersActivemqSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersJmsArtemisSource= catalog.getKameletSupportedHeaders("jms-apache-artemis-source");
+ assertEquals(14, headersJmsArtemisSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersJmsArtemisSink= catalog.getKameletSupportedHeaders("jms-apache-artemis-sink");
+ assertEquals(17, headersJmsArtemisSink.size());
}
}
[camel-kamelets] 04/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS ActiveMQ
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 365ae37fe56bbe773eb16d47aab6167072a177ba
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 10:39:47 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS ActiveMQ
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 ce85b707..422f7e5b 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
@@ -73,7 +73,8 @@ public enum KameletPrefixSchemeEnum {
jira("jira", "jira"),
jira_transition_issue("jira-transition-issue", "jira"),
jira_update_issue("jira-update-issue", "jira"),
- jms_amqp_10("jms-amqp-10", "jms");
+ jms_amqp_10("jms-amqp-10", "jms"),
+ jms_apache_activemq("jms-apache-activemq", "activemq");
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 d685280c..f881636d 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
@@ -230,5 +230,9 @@ public class KameletsCatalogTest {
assertEquals(14, headersJmsAmqp10Source.size());
List<ComponentModel.EndpointHeaderModel> headersJmsAmqp10Sink= catalog.getKameletSupportedHeaders("jms-amqp-10-sink");
assertEquals(17, headersJmsAmqp10Sink.size());
+ List<ComponentModel.EndpointHeaderModel> headersActivemqSource= catalog.getKameletSupportedHeaders("jms-apache-activemq-source");
+ assertEquals(0, headersActivemqSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersActivemqSink= catalog.getKameletSupportedHeaders("jms-apache-activemq-sink");
+ assertEquals(0, headersActivemqSink.size());
}
}
[camel-kamelets] 10/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Mail
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 0b2527576d31efb40d62776c445b10b11a4d50ca
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 11:05:24 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Mail
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 9625b675..2c0064f2 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
@@ -83,7 +83,8 @@ public enum KameletPrefixSchemeEnum {
kubernetes_namespaces("kubernetes-namespaces", "kubernetes-namespaces"),
kubernetes_nodes("kubernetes-nodes", "kubernetes-nodes"),
kubernetes_pods("kubernetes-pods", "kubernetes-pods"),
- log("log", "log");
+ log("log", "log"),
+ mail("mail", "imaps");
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 85838e1b..6de6007f 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
@@ -262,5 +262,9 @@ public class KameletsCatalogTest {
assertEquals(2, headersKubePodsSource.size());
List<ComponentModel.EndpointHeaderModel> headersLogSink= catalog.getKameletSupportedHeaders("log-sink");
assertEquals(0, headersLogSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersMailSource= catalog.getKameletSupportedHeaders("mail-source");
+ assertEquals(0, headersMailSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersMailSink= catalog.getKameletSupportedHeaders("mail-sink");
+ assertEquals(8, headersMailSink.size());
}
}
[camel-kamelets] 09/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Log
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 4624f67c1de311d475b040a749361199994f07d1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 10:58:15 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Log
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++-
.../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 2 ++
2 files changed, 4 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 5061c655..9625b675 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
@@ -82,7 +82,8 @@ public enum KameletPrefixSchemeEnum {
kafka_ssl("kafka-ssl", "kafka"),
kubernetes_namespaces("kubernetes-namespaces", "kubernetes-namespaces"),
kubernetes_nodes("kubernetes-nodes", "kubernetes-nodes"),
- kubernetes_pods("kubernetes-pods", "kubernetes-pods");
+ kubernetes_pods("kubernetes-pods", "kubernetes-pods"),
+ log("log", "log");
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 bee415fc..85838e1b 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
@@ -260,5 +260,7 @@ public class KameletsCatalogTest {
assertEquals(2, headersKubeNodesSource.size());
List<ComponentModel.EndpointHeaderModel> headersKubePodsSource= catalog.getKameletSupportedHeaders("kubernetes-pods-source");
assertEquals(2, headersKubePodsSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersLogSink= catalog.getKameletSupportedHeaders("log-sink");
+ assertEquals(0, headersLogSink.size());
}
}
[camel-kamelets] 02/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JIRA
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 18d6d7e31c38fa613f43fe128ae6cd7706d3fe5f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 10:26:38 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JIRA
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++
1 file changed, 4 insertions(+)
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 19b10333..6818d1b0 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
@@ -222,5 +222,9 @@ public class KameletsCatalogTest {
assertEquals(16, headersJiraAddCommentSink.size());
List<ComponentModel.EndpointHeaderModel> headersJiraAddIssueSink = catalog.getKameletSupportedHeaders("jira-add-issue-sink");
assertEquals(16, headersJiraAddIssueSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersJiraSource= catalog.getKameletSupportedHeaders("jira-source");
+ assertEquals(3, headersJiraSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersJiraOauthSource= catalog.getKameletSupportedHeaders("jira-oauth-source");
+ assertEquals(3, headersJiraOauthSource.size());
}
}
[camel-kamelets] 08/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Kubernetes
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 2aef3680e35e9a64b7211c775b04407dcb44c831
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 10:56:07 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Kubernetes
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 5 ++++-
.../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 6 ++++++
2 files changed, 10 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 73c151af..5061c655 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
@@ -79,7 +79,10 @@ public enum KameletPrefixSchemeEnum {
jms_ibm_mq("jms-ibm-mq", "jms"),
kafka("kafka", "kafka"),
kafka_not_secured("kafka-not-secured", "kafka"),
- kafka_ssl("kafka-ssl", "kafka");
+ kafka_ssl("kafka-ssl", "kafka"),
+ kubernetes_namespaces("kubernetes-namespaces", "kubernetes-namespaces"),
+ kubernetes_nodes("kubernetes-nodes", "kubernetes-nodes"),
+ kubernetes_pods("kubernetes-pods", "kubernetes-pods");
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 55bd01ea..bee415fc 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
@@ -254,5 +254,11 @@ public class KameletsCatalogTest {
assertEquals(9, headersKafkaNotSecuredSource.size());
List<ComponentModel.EndpointHeaderModel> headersKafkaNotSecuredSink= catalog.getKameletSupportedHeaders("kafka-not-secured-sink");
assertEquals(5, headersKafkaNotSecuredSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersKubeNamespacesSource= catalog.getKameletSupportedHeaders("kubernetes-namespaces-source");
+ assertEquals(2, headersKubeNamespacesSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersKubeNodesSource= catalog.getKameletSupportedHeaders("kubernetes-nodes-source");
+ assertEquals(2, headersKubeNodesSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersKubePodsSource= catalog.getKameletSupportedHeaders("kubernetes-pods-source");
+ assertEquals(2, headersKubePodsSource.size());
}
}
[camel-kamelets] 06/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS IBM MQ
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 aabfc3dfd05129ba13826924ff3412fff8645ec8
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 10:44:03 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - JMS IBM MQ
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 23d80512..5265efe9 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
@@ -75,7 +75,8 @@ public enum KameletPrefixSchemeEnum {
jira_update_issue("jira-update-issue", "jira"),
jms_amqp_10("jms-amqp-10", "jms"),
jms_apache_activemq("jms-apache-activemq", "activemq"),
- jms_apache_artemis("jms-apache-artemis", "jms");
+ jms_apache_artemis("jms-apache-artemis", "jms"),
+ jms_ibm_mq("jms-ibm-mq", "jms");
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 a11c894b..f1e89528 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
@@ -238,5 +238,9 @@ public class KameletsCatalogTest {
assertEquals(14, headersJmsArtemisSource.size());
List<ComponentModel.EndpointHeaderModel> headersJmsArtemisSink= catalog.getKameletSupportedHeaders("jms-apache-artemis-sink");
assertEquals(17, headersJmsArtemisSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersJmsIBMSource= catalog.getKameletSupportedHeaders("jms-ibm-mq-source");
+ assertEquals(14, headersJmsIBMSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersJmsIBMSink= catalog.getKameletSupportedHeaders("jms-ibm-mq-sink");
+ assertEquals(17, headersJmsIBMSink.size());
}
}
[camel-kamelets] 07/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Kafka
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 a967ae6bbe2ea86bb1cefc1220a192a32fb14149
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 10:51:34 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Kafka
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../kamelets/catalog/model/KameletPrefixSchemeEnum.java | 5 ++++-
.../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 12 ++++++++++++
2 files changed, 16 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 5265efe9..73c151af 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
@@ -76,7 +76,10 @@ public enum KameletPrefixSchemeEnum {
jms_amqp_10("jms-amqp-10", "jms"),
jms_apache_activemq("jms-apache-activemq", "activemq"),
jms_apache_artemis("jms-apache-artemis", "jms"),
- jms_ibm_mq("jms-ibm-mq", "jms");
+ jms_ibm_mq("jms-ibm-mq", "jms"),
+ kafka("kafka", "kafka"),
+ kafka_not_secured("kafka-not-secured", "kafka"),
+ kafka_ssl("kafka-ssl", "kafka");
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 f1e89528..55bd01ea 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
@@ -242,5 +242,17 @@ public class KameletsCatalogTest {
assertEquals(14, headersJmsIBMSource.size());
List<ComponentModel.EndpointHeaderModel> headersJmsIBMSink= catalog.getKameletSupportedHeaders("jms-ibm-mq-sink");
assertEquals(17, headersJmsIBMSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersKafkaSource= catalog.getKameletSupportedHeaders("kafka-source");
+ assertEquals(9, headersKafkaSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersKafkaSink= catalog.getKameletSupportedHeaders("kafka-sink");
+ assertEquals(5, headersKafkaSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersKafkaSSLSource= catalog.getKameletSupportedHeaders("kafka-ssl-source");
+ assertEquals(9, headersKafkaSSLSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersKafkaSSLSink= catalog.getKameletSupportedHeaders("kafka-ssl-sink");
+ assertEquals(5, headersKafkaSSLSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersKafkaNotSecuredSource= catalog.getKameletSupportedHeaders("kafka-not-secured-source");
+ assertEquals(9, headersKafkaNotSecuredSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersKafkaNotSecuredSink= catalog.getKameletSupportedHeaders("kafka-not-secured-sink");
+ assertEquals(5, headersKafkaNotSecuredSink.size());
}
}
[camel-kamelets] 11/11: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SQL
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 eba4773e0f0ae6cfa43b3022b76dd712814ff568
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Wed Oct 19 11:08:39 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SQL
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 2c0064f2..82cec34c 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
@@ -84,7 +84,8 @@ public enum KameletPrefixSchemeEnum {
kubernetes_nodes("kubernetes-nodes", "kubernetes-nodes"),
kubernetes_pods("kubernetes-pods", "kubernetes-pods"),
log("log", "log"),
- mail("mail", "imaps");
+ mail("mail", "imaps"),
+ mariadb("mariadb", "sql");
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 6de6007f..7355db88 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
@@ -266,5 +266,9 @@ public class KameletsCatalogTest {
assertEquals(0, headersMailSource.size());
List<ComponentModel.EndpointHeaderModel> headersMailSink= catalog.getKameletSupportedHeaders("mail-sink");
assertEquals(8, headersMailSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersMariaDBSource= catalog.getKameletSupportedHeaders("mariadb-source");
+ assertEquals(0, headersMariaDBSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersMariaDBSink= catalog.getKameletSupportedHeaders("mariadb-sink");
+ assertEquals(8, headersMariaDBSink.size());
}
}