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/20 12:43:24 UTC
[camel-kamelets] branch main updated (c570282f -> 6c61b447)
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 c570282f Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MongoDB
new f65b7449 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MQTT
new edc83e09 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MQTT5
new 952a3b51 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MySQL
new 134f611c Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - NATS
new 0440a961 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Oracle Database
new c23fd727 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - PostgreSQL
new 20297721 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Pulsar
new 99a39782 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - RabbitMQ
new 2bb4c9a0 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Redis
new 5b087d8b Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Rest OpenAPI
new f2be38e8 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Salesforce
new 04e272c6 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SCP/SFTP
new 02fac6fa Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Slack
new 367c56f7 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Solr
new a5c44a66 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Splunk
new 06267bdc Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SQLServer
new 455cc599 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SSH
new f826814f Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Telegram
new 1aaa3e88 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Timer
new 25d5a132 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Twitter
new 6c61b447 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Webhook, Websocket and Wttrin
The 21 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 | 32 +++++++-
.../kamelets/catalog/KameletsCatalogTest.java | 92 ++++++++++++++++++++++
2 files changed, 123 insertions(+), 1 deletion(-)
[camel-kamelets] 09/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Redis
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 2bb4c9a0dff86e9837b880df3096225446fb884d
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:33:20 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Redis
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 b87cd45a..17ca3406 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
@@ -96,7 +96,8 @@ public enum KameletPrefixSchemeEnum {
oracle_database("oracle-database", "sql"),
postgresql("postgresql", "sql"),
pulsar("pulsar", "pulsar"),
- rabbitmq("rabbitmq", "rabbitmq");
+ rabbitmq("rabbitmq", "rabbitmq"),
+ redis("redis", "spring-redis");
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 9cd3fa96..9dbcea0c 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
@@ -312,5 +312,9 @@ public class KameletsCatalogTest {
assertEquals(11, headersPulsarSource.size());
List<ComponentModel.EndpointHeaderModel> headersRabbitMQSource= catalog.getKameletSupportedHeaders("rabbitmq-source");
assertEquals(23, headersRabbitMQSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersRedisSink= catalog.getKameletSupportedHeaders("redis-sink");
+ assertEquals(29, headersRedisSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersRedisSource= catalog.getKameletSupportedHeaders("redis-source");
+ assertEquals(28, headersRedisSource.size());
}
}
[camel-kamelets] 21/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Webhook, Websocket and Wttrin
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 6c61b44731b4977bbb08cb24430b533ea9cc09bb
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 14:34:57 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Webhook, Websocket and Wttrin
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 26f665a6..ed52ee89 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
@@ -115,7 +115,10 @@ public enum KameletPrefixSchemeEnum {
timer("timer", "timer"),
twitter_directmessage("twitter-directmessage", "twitter-directmessage"),
twitter_timeline("twitter-timeline", "twitter-timeline"),
- twitter_search("twitter-search", "twitter-search"),;
+ twitter_search("twitter-search", "twitter-search"),
+ webhook("webhook", "platform-http"),
+ websocket("websocket", "websocket"),
+ wttrin("wttrin", "https");
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 287eb711..84ddf8ea 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
@@ -366,5 +366,11 @@ public class KameletsCatalogTest {
assertEquals(1, headersTwitterTimelineSource.size());
List<ComponentModel.EndpointHeaderModel> headersTwitterSearchSource= catalog.getKameletSupportedHeaders("twitter-search-source");
assertEquals(7, headersTwitterSearchSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersWebhookSource= catalog.getKameletSupportedHeaders("webhook-source");
+ assertEquals(0, headersWebhookSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersWebsocketSource= catalog.getKameletSupportedHeaders("websocket-source");
+ assertEquals(4, headersWebsocketSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersWttrinSource= catalog.getKameletSupportedHeaders("wttrin-source");
+ assertEquals(5, headersWttrinSource.size());
}
}
[camel-kamelets] 15/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Splunk
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 a5c44a667f77f8b0d2bd1f47ecc7b986ce7bd3bd
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:54:05 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Splunk
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 c0ff9d4c..21b58770 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
@@ -106,7 +106,9 @@ public enum KameletPrefixSchemeEnum {
scp("scp", "scp"),
sftp("sftp", "sftp"),
slack("slack", "slack"),
- solr("solr", "solr");
+ solr("solr", "solr"),
+ splunk_hec("splunk-hec", "splunk-hec"),
+ splunk("splunk", "splunk");
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 f59985cb..c0e66b78 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
@@ -340,5 +340,11 @@ public class KameletsCatalogTest {
assertEquals(5, headersSolrSink.size());
List<ComponentModel.EndpointHeaderModel> headersSolrSource= catalog.getKameletSupportedHeaders("solr-source");
assertEquals(5, headersSolrSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersSplunkHecSink= catalog.getKameletSupportedHeaders("splunk-hec-sink");
+ assertEquals(1, headersSplunkHecSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSplunkSink= catalog.getKameletSupportedHeaders("splunk-sink");
+ assertEquals(0, headersSplunkSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSplunkSource= catalog.getKameletSupportedHeaders("splunk-source");
+ assertEquals(0, headersSplunkSource.size());
}
}
[camel-kamelets] 06/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - PostgreSQL
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 c23fd72785a014115831a3c757a63998b22e974c
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:22:59 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - PostgreSQL
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 9cfd9d0f..426bf3a5 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
@@ -93,7 +93,8 @@ public enum KameletPrefixSchemeEnum {
mqtt5("mqtt5", "paho-mqtt5"),
mysql("mysql", "sql"),
nats("nats", "nats"),
- oracle_database("oracle-database", "sql");
+ oracle_database("oracle-database", "sql"),
+ postgresql("postgresql", "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 1375cb1d..0b274170 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
@@ -302,5 +302,9 @@ public class KameletsCatalogTest {
assertEquals(8, headersOracleDBSink.size());
List<ComponentModel.EndpointHeaderModel> headersOracleDBSource= catalog.getKameletSupportedHeaders("oracle-database-source");
assertEquals(0, headersOracleDBSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersPostgreSQLSink= catalog.getKameletSupportedHeaders("postgresql-sink");
+ assertEquals(8, headersPostgreSQLSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersPostgreSQLSource= catalog.getKameletSupportedHeaders("postgresql-source");
+ assertEquals(0, headersPostgreSQLSource.size());
}
}
[camel-kamelets] 01/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MQTT
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 f65b7449ec3e9848935e209c693e81f26ff49a72
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:03:33 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MQTT
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 4562db9c..a14e2a7e 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
@@ -88,7 +88,8 @@ public enum KameletPrefixSchemeEnum {
mariadb("mariadb", "sql"),
minio("minio", "minio"),
mongodb_changes_stream("mongodb-changes-stream", "mongodb"),
- mongodb("mongodb", "mongodb");
+ mongodb("mongodb", "mongodb"),
+ mqtt("mqtt", "paho");
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 cb894480..a133a2ce 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
@@ -280,5 +280,9 @@ public class KameletsCatalogTest {
assertEquals(12, headersMongoDbSink.size());
List<ComponentModel.EndpointHeaderModel> headersMongoDbSource= catalog.getKameletSupportedHeaders("mongodb-source");
assertEquals(3, headersMongoDbSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersMQTTSink= catalog.getKameletSupportedHeaders("mqtt-sink");
+ assertEquals(3, headersMQTTSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersMQTTSource= catalog.getKameletSupportedHeaders("mqtt-source");
+ assertEquals(2, headersMQTTSource.size());
}
}
[camel-kamelets] 14/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Solr
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 367c56f72583cdd2d8da945e86c1182e4e4f6abf
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:51:02 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Solr
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 d52d46bc..c0ff9d4c 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
@@ -105,7 +105,8 @@ public enum KameletPrefixSchemeEnum {
salesforce("salesforce", "salesforce"),
scp("scp", "scp"),
sftp("sftp", "sftp"),
- slack("slack", "slack");
+ slack("slack", "slack"),
+ solr("solr", "solr");
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 8bb1286d..f59985cb 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
@@ -336,5 +336,9 @@ public class KameletsCatalogTest {
assertEquals(0, headersSlackSink.size());
List<ComponentModel.EndpointHeaderModel> headersSlackSource= catalog.getKameletSupportedHeaders("slack-source");
assertEquals(0, headersSlackSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersSolrSink= catalog.getKameletSupportedHeaders("solr-sink");
+ assertEquals(5, headersSolrSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSolrSource= catalog.getKameletSupportedHeaders("solr-source");
+ assertEquals(5, headersSolrSource.size());
}
}
[camel-kamelets] 08/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - RabbitMQ
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 99a39782daf9d6c6f3edff6209feadb17feb06a1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:29:26 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - RabbitMQ
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 d3ae6860..b87cd45a 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
@@ -95,7 +95,8 @@ public enum KameletPrefixSchemeEnum {
nats("nats", "nats"),
oracle_database("oracle-database", "sql"),
postgresql("postgresql", "sql"),
- pulsar("pulsar", "pulsar");
+ pulsar("pulsar", "pulsar"),
+ rabbitmq("rabbitmq", "rabbitmq");
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 da1cac32..9cd3fa96 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
@@ -310,5 +310,7 @@ public class KameletsCatalogTest {
assertEquals(3, headersPulsarSink.size());
List<ComponentModel.EndpointHeaderModel> headersPulsarSource= catalog.getKameletSupportedHeaders("pulsar-source");
assertEquals(11, headersPulsarSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersRabbitMQSource= catalog.getKameletSupportedHeaders("rabbitmq-source");
+ assertEquals(23, headersRabbitMQSource.size());
}
}
[camel-kamelets] 04/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - NATS
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 134f611cccc2ee5d30d95c5f033ecc8e4feb6f8b
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:15:07 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - NATS
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 dc78471b..8b1cdc53 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
@@ -91,7 +91,8 @@ public enum KameletPrefixSchemeEnum {
mongodb("mongodb", "mongodb"),
mqtt("mqtt", "paho"),
mqtt5("mqtt5", "paho-mqtt5"),
- mysql("mysql", "sql");
+ mysql("mysql", "sql"),
+ nats("nats", "nats");
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 d474574a..681f673a 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
@@ -294,5 +294,9 @@ public class KameletsCatalogTest {
assertEquals(8, headersMySQLSink.size());
List<ComponentModel.EndpointHeaderModel> headersMySQLSource= catalog.getKameletSupportedHeaders("mysql-source");
assertEquals(0, headersMySQLSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersNatsSink= catalog.getKameletSupportedHeaders("nats-sink");
+ assertEquals(5, headersNatsSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersNatsSource= catalog.getKameletSupportedHeaders("nats-source");
+ assertEquals(5, headersNatsSource.size());
}
}
[camel-kamelets] 10/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Rest OpenAPI
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 5b087d8b796af3218ca8acd1986b60c6b0dedbb0
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:35:12 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Rest OpenAPI
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 17ca3406..e8e195c3 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
@@ -97,7 +97,8 @@ public enum KameletPrefixSchemeEnum {
postgresql("postgresql", "sql"),
pulsar("pulsar", "pulsar"),
rabbitmq("rabbitmq", "rabbitmq"),
- redis("redis", "spring-redis");
+ redis("redis", "spring-redis"),
+ rest_openapi("rest-openapi", "rest-openapi");
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 9dbcea0c..8a6f27a8 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
@@ -316,5 +316,7 @@ public class KameletsCatalogTest {
assertEquals(29, headersRedisSink.size());
List<ComponentModel.EndpointHeaderModel> headersRedisSource= catalog.getKameletSupportedHeaders("redis-source");
assertEquals(28, headersRedisSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersRestOpenAPISink= catalog.getKameletSupportedHeaders("rest-openapi-sink");
+ assertEquals(0, headersRestOpenAPISink.size());
}
}
[camel-kamelets] 11/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Salesforce
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 f2be38e82c9246ca4986a7aef7a6a77bc7d2b04f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:40:20 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Salesforce
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 6 +++++-
.../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 8 ++++++++
2 files changed, 13 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 e8e195c3..c5243796 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
@@ -98,7 +98,11 @@ public enum KameletPrefixSchemeEnum {
pulsar("pulsar", "pulsar"),
rabbitmq("rabbitmq", "rabbitmq"),
redis("redis", "spring-redis"),
- rest_openapi("rest-openapi", "rest-openapi");
+ rest_openapi("rest-openapi", "rest-openapi"),
+ salesforce_create("salesforce-create", "salesforce"),
+ salesforce_delete("salesforce-delete", "salesforce"),
+ salesforce_update("salesforce-update", "salesforce"),
+ salesforce("salesforce", "salesforce");
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 8a6f27a8..f6c4483f 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
@@ -318,5 +318,13 @@ public class KameletsCatalogTest {
assertEquals(28, headersRedisSource.size());
List<ComponentModel.EndpointHeaderModel> headersRestOpenAPISink= catalog.getKameletSupportedHeaders("rest-openapi-sink");
assertEquals(0, headersRestOpenAPISink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSalesforceCreateSink= catalog.getKameletSupportedHeaders("salesforce-create-sink");
+ assertEquals(1, headersSalesforceCreateSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSalesforceDeleteSink= catalog.getKameletSupportedHeaders("salesforce-delete-sink");
+ assertEquals(1, headersSalesforceDeleteSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSalesforceUpdateSink= catalog.getKameletSupportedHeaders("salesforce-update-sink");
+ assertEquals(1, headersSalesforceUpdateSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSalesforceSource= catalog.getKameletSupportedHeaders("salesforce-source");
+ assertEquals(18, headersSalesforceSource.size());
}
}
[camel-kamelets] 19/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Timer
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 1aaa3e8873a9fb33a2aee744425dd8d31b6de9eb
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 14:11:44 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Timer
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 3eb87bfd..a1e70f83 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
@@ -111,7 +111,8 @@ public enum KameletPrefixSchemeEnum {
splunk("splunk", "splunk"),
sqlserver("sqlserver", "sql"),
ssh("ssh", "ssh"),
- telegram("telegram", "telegram");
+ telegram("telegram", "telegram"),
+ timer("timer", "timer");
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 449ee46c..d622fa51 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
@@ -358,5 +358,7 @@ public class KameletsCatalogTest {
assertEquals(6, headersTelegramSink.size());
List<ComponentModel.EndpointHeaderModel> headersTelegramSource= catalog.getKameletSupportedHeaders("telegram-source");
assertEquals(5, headersTelegramSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersTimerSource= catalog.getKameletSupportedHeaders("timer-source");
+ assertEquals(2, headersTimerSource.size());
}
}
[camel-kamelets] 20/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Twitter
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 25d5a1327589940452942d9e9a3046141dc09bac
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 14:15:23 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Twitter
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 a1e70f83..26f665a6 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
@@ -112,7 +112,10 @@ public enum KameletPrefixSchemeEnum {
sqlserver("sqlserver", "sql"),
ssh("ssh", "ssh"),
telegram("telegram", "telegram"),
- timer("timer", "timer");
+ timer("timer", "timer"),
+ twitter_directmessage("twitter-directmessage", "twitter-directmessage"),
+ twitter_timeline("twitter-timeline", "twitter-timeline"),
+ twitter_search("twitter-search", "twitter-search"),;
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 d622fa51..287eb711 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
@@ -360,5 +360,11 @@ public class KameletsCatalogTest {
assertEquals(5, headersTelegramSource.size());
List<ComponentModel.EndpointHeaderModel> headersTimerSource= catalog.getKameletSupportedHeaders("timer-source");
assertEquals(2, headersTimerSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersTwitterDMSource= catalog.getKameletSupportedHeaders("twitter-directmessage-source");
+ assertEquals(2, headersTwitterDMSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersTwitterTimelineSource= catalog.getKameletSupportedHeaders("twitter-timeline-source");
+ assertEquals(1, headersTwitterTimelineSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersTwitterSearchSource= catalog.getKameletSupportedHeaders("twitter-search-source");
+ assertEquals(7, headersTwitterSearchSource.size());
}
}
[camel-kamelets] 05/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Oracle Database
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 0440a96117607791d63b85c208eb42cc3508523a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:21:18 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Oracle Database
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 8b1cdc53..9cfd9d0f 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
@@ -92,7 +92,8 @@ public enum KameletPrefixSchemeEnum {
mqtt("mqtt", "paho"),
mqtt5("mqtt5", "paho-mqtt5"),
mysql("mysql", "sql"),
- nats("nats", "nats");
+ nats("nats", "nats"),
+ oracle_database("oracle-database", "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 681f673a..1375cb1d 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
@@ -298,5 +298,9 @@ public class KameletsCatalogTest {
assertEquals(5, headersNatsSink.size());
List<ComponentModel.EndpointHeaderModel> headersNatsSource= catalog.getKameletSupportedHeaders("nats-source");
assertEquals(5, headersNatsSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersOracleDBSink= catalog.getKameletSupportedHeaders("oracle-database-sink");
+ assertEquals(8, headersOracleDBSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersOracleDBSource= catalog.getKameletSupportedHeaders("oracle-database-source");
+ assertEquals(0, headersOracleDBSource.size());
}
}
[camel-kamelets] 02/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MQTT5
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 edc83e09976d82ceb66612ad0768b5824c8bbc31
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:08:46 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MQTT5
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 a14e2a7e..58923c50 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
@@ -89,7 +89,8 @@ public enum KameletPrefixSchemeEnum {
minio("minio", "minio"),
mongodb_changes_stream("mongodb-changes-stream", "mongodb"),
mongodb("mongodb", "mongodb"),
- mqtt("mqtt", "paho");
+ mqtt("mqtt", "paho"),
+ mqtt5("mqtt5", "paho-mqtt5");
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 a133a2ce..78c97438 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
@@ -284,5 +284,9 @@ public class KameletsCatalogTest {
assertEquals(3, headersMQTTSink.size());
List<ComponentModel.EndpointHeaderModel> headersMQTTSource= catalog.getKameletSupportedHeaders("mqtt-source");
assertEquals(2, headersMQTTSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersMQTT5Sink= catalog.getKameletSupportedHeaders("mqtt5-sink");
+ assertEquals(3, headersMQTT5Sink.size());
+ List<ComponentModel.EndpointHeaderModel> headersMQTT5Source= catalog.getKameletSupportedHeaders("mqtt5-source");
+ assertEquals(2, headersMQTT5Source.size());
}
}
[camel-kamelets] 17/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SSH
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 455cc599ce0c7d178a924b4d4dc346031c8dd247
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 14:06:57 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SSH
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 35711f65..d00a3c8c 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
@@ -109,7 +109,8 @@ public enum KameletPrefixSchemeEnum {
solr("solr", "solr"),
splunk_hec("splunk-hec", "splunk-hec"),
splunk("splunk", "splunk"),
- sqlserver("sqlserver", "sql");
+ sqlserver("sqlserver", "sql"),
+ ssh("ssh", "ssh");
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 20c689db..eaedd684 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
@@ -350,5 +350,9 @@ public class KameletsCatalogTest {
assertEquals(8, headersSqlServerSink.size());
List<ComponentModel.EndpointHeaderModel> headersSqlServerSource= catalog.getKameletSupportedHeaders("sqlserver-source");
assertEquals(0, headersSqlServerSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersSSHSink= catalog.getKameletSupportedHeaders("ssh-sink");
+ assertEquals(4, headersSSHSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSSHSource= catalog.getKameletSupportedHeaders("ssh-source");
+ assertEquals(4, headersSSHSource.size());
}
}
[camel-kamelets] 03/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MySQL
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 952a3b5161bcdeeb9f217b5c2ee7459912273748
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:12:23 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MySQL
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++-
.../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 6 ++++++
2 files changed, 8 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 58923c50..dc78471b 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
@@ -90,7 +90,8 @@ public enum KameletPrefixSchemeEnum {
mongodb_changes_stream("mongodb-changes-stream", "mongodb"),
mongodb("mongodb", "mongodb"),
mqtt("mqtt", "paho"),
- mqtt5("mqtt5", "paho-mqtt5");
+ mqtt5("mqtt5", "paho-mqtt5"),
+ mysql("mysql", "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 78c97438..d474574a 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
@@ -132,6 +132,8 @@ public class KameletsCatalogTest {
assertEquals(18, headersSource.size());
List<ComponentModel.EndpointHeaderModel> headersSink = catalog.getKameletSupportedHeaders("aws-s3-sink");
assertEquals(25, headersSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersRedshiftSource = catalog.getKameletSupportedHeaders("aws-redshift-source");
+ assertEquals(0, headersRedshiftSource.size());
List<ComponentModel.EndpointHeaderModel> headerNotExistent = catalog.getKameletSupportedHeaders("aws-not-exists");
assertEquals(0, headerNotExistent.size());
List<ComponentModel.EndpointHeaderModel> headersAzureSink = catalog.getKameletSupportedHeaders("azure-eventhubs-sink");
@@ -288,5 +290,9 @@ public class KameletsCatalogTest {
assertEquals(3, headersMQTT5Sink.size());
List<ComponentModel.EndpointHeaderModel> headersMQTT5Source= catalog.getKameletSupportedHeaders("mqtt5-source");
assertEquals(2, headersMQTT5Source.size());
+ List<ComponentModel.EndpointHeaderModel> headersMySQLSink= catalog.getKameletSupportedHeaders("mysql-sink");
+ assertEquals(8, headersMySQLSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersMySQLSource= catalog.getKameletSupportedHeaders("mysql-source");
+ assertEquals(0, headersMySQLSource.size());
}
}
[camel-kamelets] 07/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Pulsar
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 202977219f61ad16e18dce38e86384fa03bb1f78
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:26:50 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Pulsar
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 426bf3a5..d3ae6860 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
@@ -94,7 +94,8 @@ public enum KameletPrefixSchemeEnum {
mysql("mysql", "sql"),
nats("nats", "nats"),
oracle_database("oracle-database", "sql"),
- postgresql("postgresql", "sql");
+ postgresql("postgresql", "sql"),
+ pulsar("pulsar", "pulsar");
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 0b274170..da1cac32 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
@@ -306,5 +306,9 @@ public class KameletsCatalogTest {
assertEquals(8, headersPostgreSQLSink.size());
List<ComponentModel.EndpointHeaderModel> headersPostgreSQLSource= catalog.getKameletSupportedHeaders("postgresql-source");
assertEquals(0, headersPostgreSQLSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersPulsarSink= catalog.getKameletSupportedHeaders("pulsar-sink");
+ assertEquals(3, headersPulsarSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersPulsarSource= catalog.getKameletSupportedHeaders("pulsar-source");
+ assertEquals(11, headersPulsarSource.size());
}
}
[camel-kamelets] 18/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Telegram
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 f826814f581ca7ed43cad2fd7705df29b6e5206a
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 14:10:11 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Telegram
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 d00a3c8c..3eb87bfd 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
@@ -110,7 +110,8 @@ public enum KameletPrefixSchemeEnum {
splunk_hec("splunk-hec", "splunk-hec"),
splunk("splunk", "splunk"),
sqlserver("sqlserver", "sql"),
- ssh("ssh", "ssh");
+ ssh("ssh", "ssh"),
+ telegram("telegram", "telegram");
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 eaedd684..449ee46c 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
@@ -354,5 +354,9 @@ public class KameletsCatalogTest {
assertEquals(4, headersSSHSink.size());
List<ComponentModel.EndpointHeaderModel> headersSSHSource= catalog.getKameletSupportedHeaders("ssh-source");
assertEquals(4, headersSSHSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersTelegramSink= catalog.getKameletSupportedHeaders("telegram-sink");
+ assertEquals(6, headersTelegramSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersTelegramSource= catalog.getKameletSupportedHeaders("telegram-source");
+ assertEquals(5, headersTelegramSource.size());
}
}
[camel-kamelets] 12/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SCP/SFTP
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 04e272c6aecebe0d8d6a4b0da1c7a8f6de47558f
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:46:01 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SCP/SFTP
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 c5243796..b7e2af76 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
@@ -102,7 +102,9 @@ public enum KameletPrefixSchemeEnum {
salesforce_create("salesforce-create", "salesforce"),
salesforce_delete("salesforce-delete", "salesforce"),
salesforce_update("salesforce-update", "salesforce"),
- salesforce("salesforce", "salesforce");
+ salesforce("salesforce", "salesforce"),
+ scp("scp", "scp"),
+ sftp("sftp", "sftp");
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 f6c4483f..ca0d20b6 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
@@ -326,5 +326,11 @@ public class KameletsCatalogTest {
assertEquals(1, headersSalesforceUpdateSink.size());
List<ComponentModel.EndpointHeaderModel> headersSalesforceSource= catalog.getKameletSupportedHeaders("salesforce-source");
assertEquals(18, headersSalesforceSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersSCPSink= catalog.getKameletSupportedHeaders("scp-sink");
+ assertEquals(0, headersSCPSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSFTPSink= catalog.getKameletSupportedHeaders("sftp-sink");
+ assertEquals(8, headersSFTPSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSFTPSource= catalog.getKameletSupportedHeaders("sftp-source");
+ assertEquals(10, headersSFTPSource.size());
}
}
[camel-kamelets] 16/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SQLServer
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 06267bdce8e398a0355dc23fcf953121607f8691
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:56:56 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SQLServer
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 21b58770..35711f65 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
@@ -108,7 +108,8 @@ public enum KameletPrefixSchemeEnum {
slack("slack", "slack"),
solr("solr", "solr"),
splunk_hec("splunk-hec", "splunk-hec"),
- splunk("splunk", "splunk");
+ splunk("splunk", "splunk"),
+ sqlserver("sqlserver", "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 c0e66b78..20c689db 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
@@ -346,5 +346,9 @@ public class KameletsCatalogTest {
assertEquals(0, headersSplunkSink.size());
List<ComponentModel.EndpointHeaderModel> headersSplunkSource= catalog.getKameletSupportedHeaders("splunk-source");
assertEquals(0, headersSplunkSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersSqlServerSink= catalog.getKameletSupportedHeaders("sqlserver-sink");
+ assertEquals(8, headersSqlServerSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSqlServerSource= catalog.getKameletSupportedHeaders("sqlserver-source");
+ assertEquals(0, headersSqlServerSource.size());
}
}
[camel-kamelets] 13/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Slack
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 02fac6fa245d33a944d7d253a89358fb933eefd1
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Thu Oct 20 13:48:04 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Slack
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 b7e2af76..d52d46bc 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
@@ -104,7 +104,8 @@ public enum KameletPrefixSchemeEnum {
salesforce_update("salesforce-update", "salesforce"),
salesforce("salesforce", "salesforce"),
scp("scp", "scp"),
- sftp("sftp", "sftp");
+ sftp("sftp", "sftp"),
+ slack("slack", "slack");
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 ca0d20b6..8bb1286d 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
@@ -332,5 +332,9 @@ public class KameletsCatalogTest {
assertEquals(8, headersSFTPSink.size());
List<ComponentModel.EndpointHeaderModel> headersSFTPSource= catalog.getKameletSupportedHeaders("sftp-source");
assertEquals(10, headersSFTPSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersSlackSink= catalog.getKameletSupportedHeaders("slack-sink");
+ assertEquals(0, headersSlackSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersSlackSource= catalog.getKameletSupportedHeaders("slack-source");
+ assertEquals(0, headersSlackSource.size());
}
}