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

…nsumer, producer and common) for a Kamelet - Azure Functions Signed-off-by: Andrea Cosentino <ancosen@gmail.com>
apache · Oct 14, 2022 · 51ff1bb · 51ff1bb
1 parent 78a16a6
commit 51ff1bb
Show file tree

Hide file tree

Showing 2 changed files with 4 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
@@ -32,7 +32,8 @@ public enum KameletPrefixSchemeEnum {
     aws_sqs("aws-sqs","aws2-sqs"),
     aws_sqs_batch("aws-sqs-batch","aws2-sqs"),
     aws_sqs_fifo("aws-sqs-fifo","aws2-sqs"),
-    azure_eventhubs("azure-eventhubs","azure-eventhubs");
+    azure_eventhubs("azure-eventhubs","azure-eventhubs"),
+    azure_functions("azure-functions","vertx-http");
 
     public final String label;
     public final String prefix;

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
@@ -136,5 +136,7 @@ void testSupportedHeaders() throws Exception {
         assertEquals(0, headerNotExistent.size());
         List<ComponentModel.EndpointHeaderModel> headersAzureSink = catalog.getKameletSupportedHeaders("azure-eventhubs-sink");
         assertEquals(2, headersAzureSink.size());
+        List<ComponentModel.EndpointHeaderModel> headersAzureFunctionsSink = catalog.getKameletSupportedHeaders("azure-functions-sink");
+        assertEquals(8, headersAzureFunctionsSink.size());
     }
 }