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:52 UTC
[camel-kamelets] 09/21: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Redis
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());
}
}