From 5a38e49436c5580c55cee5d420df9aef6c71c3b9 Mon Sep 17 00:00:00 2001 From: Andrea Cosentino Date: Thu, 5 Oct 2023 19:20:34 +0200 Subject: [PATCH] Kamelet Prefix Enum: Added missing entries (#1673) * KameletPrefixSchemeEnum is missing salesforce-composite-upsert Sink Kamelet Signed-off-by: Andrea Cosentino * KameletPrefixSchemeEnum is missing Azure Datalake Kamelets Signed-off-by: Andrea Cosentino --------- Signed-off-by: Andrea Cosentino --- .../camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 2 ++ .../org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 3 +++ 2 files changed, 5 insertions(+) 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 863c83806..0f212f0b1 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 @@ -38,6 +38,7 @@ public enum KameletPrefixSchemeEnum { azure_servicebus("azure-servicebus","azure-servicebus"), azure_storage_blob("azure-storage-blob","azure-storage-blob"), azure_storage_blob_changefeed("azure-storage-blob-changefeed","azure-storage-blob"), + azure_storage_datalake("azure-storage-datalake","azure-storage-datalake"), azure_storage_queue("azure-storage-queue","azure-storage-queue"), beer("beer", "http"), bitcoin("bitcoin", "xchange"), @@ -101,6 +102,7 @@ public enum KameletPrefixSchemeEnum { salesforce_create("salesforce-create", "salesforce"), salesforce_delete("salesforce-delete", "salesforce"), salesforce_update("salesforce-update", "salesforce"), + salesforce_composite_upsert("salesforce-composite-upsert", "salesforce"), salesforce("salesforce", "salesforce"), scp("scp", "scp"), sftp("sftp", "sftp"), 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 686b8e43e..1c49d3d89 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 @@ -147,6 +147,8 @@ void testSupportedHeaders() throws Exception { verifyHeaders("azure-storage-blob-source", 34); verifyHeaders("azure-storage-blob-sink", 33); verifyHeaders("azure-storage-blob-changefeed-source", 34); + verifyHeaders("azure-storage-datalake-source", 0); + verifyHeaders("azure-storage-datalake-sink", 0); verifyHeaders("azure-storage-queue-source", 6); verifyHeaders("azure-storage-queue-sink", 16); verifyHeaders("cassandra-sink", 1); @@ -232,6 +234,7 @@ void testSupportedHeaders() throws Exception { verifyHeaders("salesforce-create-sink", 1); verifyHeaders("salesforce-delete-sink", 1); verifyHeaders("salesforce-update-sink", 1); + verifyHeaders("salesforce-composite-upsert-sink", 1); verifyHeaders("salesforce-source", 19); verifyHeaders("scp-sink", 0); verifyHeaders("sftp-sink", 8);