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:36:43 UTC
[camel-kamelets] branch more-headers-support-10 created (now ef715c0f)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
at ef715c0f Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Webhook, Websocket and Wttrin
This branch includes the following new commits:
new 3f18438c Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MQTT
new ef32277c Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MQTT5
new fd71ab24 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - MySQL
new a20421ce Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - NATS
new cc870090 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Oracle Database
new 9db6b8fe Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - PostgreSQL
new 05ceb865 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Pulsar
new a59b99ab Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - RabbitMQ
new 661acad1 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Redis
new 3c317759 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Rest OpenAPI
new a84306a0 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Salesforce
new 273437e8 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SCP/SFTP
new 7476bb2b Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Slack
new 820ef3c9 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Solr
new ef94a58a Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Splunk
new ed09668d Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SQLServer
new a31db7b2 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - SSH
new 44094cea Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Telegram
new 80ab71eb Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Timer
new 740f7d73 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Twitter
new ef715c0f 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.
[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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 05ceb865c02655d765caa82db5f4ac43de0ce2db
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 3c3177596b3e92373dc2b4474dc984a6006087d7
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit ef94a58a70725de0f500560ef129e8828569cfd4
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit a31db7b2d5e48cb34368ce8bb65fa5beed0606da
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 661acad1756b0b8fd72b2df6eccc000d0139cc2c
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 44094ceafcf54fb7f90219df51df647d8aaba5b3
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 820ef3c968140064c00e7a16e0b1c86e5ddf866b
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit ef715c0f25927c44438b76592742811bd66a1826
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit cc8700905caa5ce785986c5995bfc8180f29facb
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit a59b99aba284a6a2393c76250d934ae74e147108
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit fd71ab24bd3a553128d126ce4393e80cea273aba
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit a84306a05d98f4aa2f2ba77b9b836df402eb8177
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 740f7d732dbf73001de383887ab04a7a92c7893f
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 7476bb2bad44e1438b8a1f1cc6fdf8ba85f64e7e
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());
}
}
[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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 273437e83d45a35fac1e68c68785af2abcd48e91
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit a20421ce29ab00d40ebd002e514561c06f699026
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 80ab71ebb51c46343b068a83ce98f3fbad00b7a0
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 9db6b8fecef22bab58abe3b94a2093253783cc7b
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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 3f18438c29664d88515003b38e83292a0863371f
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit ed09668d9fa22fa234b689e16ef650631dd31ce6
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] 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 more-headers-support-10
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit ef32277c4ecace3ac9b9580a334119807e761c0b
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());
}
}