This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch main in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
The following commit(s) were added to refs/heads/main by this push: new 5a38e494 Kamelet Prefix Enum: Added missing entries (#1673) 5a38e494 is described below commit 5a38e49436c5580c55cee5d420df9aef6c71c3b9 Author: Andrea Cosentino <anco...@gmail.com> AuthorDate: Thu Oct 5 19:20:34 2023 +0200 Kamelet Prefix Enum: Added missing entries (#1673) * KameletPrefixSchemeEnum is missing salesforce-composite-upsert Sink Kamelet Signed-off-by: Andrea Cosentino <anco...@gmail.com> * KameletPrefixSchemeEnum is missing Azure Datalake Kamelets Signed-off-by: Andrea Cosentino <anco...@gmail.com> --------- Signed-off-by: Andrea Cosentino <anco...@gmail.com> --- .../apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 2 ++ .../java/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 863c8380..0f212f0b 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 686b8e43..1c49d3d8 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 @@ public class KameletsCatalogTest { 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 @@ public class KameletsCatalogTest { 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);