Added a Catalog Method showing the supported headers (specific for co…

…nsumer, producer and common) for a Kamelet - Infinispan Signed-off-by: Andrea Cosentino <[email protected]>
apache · Oct 18, 2022 · 79adbcd · 79adbcd
1 parent dbdc891
commit 79adbcd
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 1 deletion.
diff --git a/...atalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java b/...atalog/src/main/java/org/apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java
@@ -65,7 +65,8 @@ public enum KameletPrefixSchemeEnum {
     google_sheets("google-sheets", "google-sheets-stream"),
     google_storage("google-storage", "google-storage"),
     http("http", "http"),
-    http_secured("http-secured", "http");
+    http_secured("http-secured", "http"),
+    infinispan("infinispan", "infinispan");
 
     public final String name;
     public final String scheme;

diff --git a/...kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java b/...kamelets-catalog/src/test/java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java
@@ -214,5 +214,9 @@ void testSupportedHeaders() throws Exception {
         assertEquals(5, headersHttpSecuredSource.size());
         List<ComponentModel.EndpointHeaderModel> headersHttpSecuredSink = catalog.getKameletSupportedHeaders("http-secured-sink");
         assertEquals(14, headersHttpSecuredSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersInfinispanSource = catalog.getKameletSupportedHeaders("infinispan-source");
+        assertEquals(6, headersInfinispanSource.size());
+        List<ComponentModel.EndpointHeaderModel> headersInfinispanSink = catalog.getKameletSupportedHeaders("infinispan-sink");
+        assertEquals(14, headersInfinispanSink.size());
     }
 }