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/14 16:29:58 UTC
[camel-kamelets] branch main updated (51ff1bb8 -> 0bd4ed5e)
This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a change to branch main
in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
from 51ff1bb8 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Functions
new b07d90e4 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Servicebus
new ae38e784 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Storage Blob
new 197e6fc2 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Storage Blob Changefeed
new 0bd4ed5e Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Storage Queue
The 4 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
.../kamelets/catalog/model/KameletPrefixSchemeEnum.java | 6 +++++-
.../apache/camel/kamelets/catalog/KameletsCatalogTest.java | 12 ++++++++++++
2 files changed, 17 insertions(+), 1 deletion(-)
[camel-kamelets] 02/04: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Storage Blob
Posted by ac...@apache.org.
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
commit ae38e78401ea269b97854af877ab454862436a21
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 14 18:17:30 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Storage Blob
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 faaa0482..1e4dd166 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
@@ -34,7 +34,8 @@ public enum KameletPrefixSchemeEnum {
aws_sqs_fifo("aws-sqs-fifo","aws2-sqs"),
azure_eventhubs("azure-eventhubs","azure-eventhubs"),
azure_functions("azure-functions","vertx-http"),
- azure_servicebus("azure-servicebus","azure-servicebus");
+ azure_servicebus("azure-servicebus","azure-servicebus"),
+ azure_storage_blob("azure-storage-blob","azure-storage-blob");
public final String label;
public final String prefix;
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 fcfd6dbd..d1976cf2 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
@@ -140,5 +140,9 @@ public class KameletsCatalogTest {
assertEquals(8, headersAzureFunctionsSink.size());
List<ComponentModel.EndpointHeaderModel> headersAzureServicebusSource = catalog.getKameletSupportedHeaders("azure-servicebus-source");
assertEquals(22, headersAzureServicebusSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersAzureStorageBlobSource = catalog.getKameletSupportedHeaders("azure-storage-blob-source");
+ assertEquals(34, headersAzureStorageBlobSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersAzureStorageBlobSink = catalog.getKameletSupportedHeaders("azure-storage-blob-sink");
+ assertEquals(32, headersAzureStorageBlobSink.size());
}
}
[camel-kamelets] 04/04: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Storage Queue
Posted by ac...@apache.org.
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
commit 0bd4ed5e92a20139136e4372d0ad8d9b11ccd130
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 14 18:25:17 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Storage Queue
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 6ad155a9..5ce8b0d5 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
@@ -36,7 +36,8 @@ public enum KameletPrefixSchemeEnum {
azure_functions("azure-functions","vertx-http"),
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_blob_changefeed("azure-storage-blob-changefeed","azure-storage-blob"),
+ azure_storage_queue("azure-storage-queue","azure-storage-queue");
public final String label;
public final String prefix;
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 6cdf5262..0008513d 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
@@ -146,5 +146,9 @@ public class KameletsCatalogTest {
assertEquals(32, headersAzureStorageBlobSink.size());
List<ComponentModel.EndpointHeaderModel> headersAzureStorageBlobChangeefeedSource = catalog.getKameletSupportedHeaders("azure-storage-blob-changefeed-source");
assertEquals(34, headersAzureStorageBlobChangeefeedSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersAzureStorageQueueSource = catalog.getKameletSupportedHeaders("azure-storage-queue-source");
+ assertEquals(6, headersAzureStorageQueueSource.size());
+ List<ComponentModel.EndpointHeaderModel> headersAzureStorageQueueSink = catalog.getKameletSupportedHeaders("azure-storage-queue-sink");
+ assertEquals(16, headersAzureStorageQueueSink.size());
}
}
[camel-kamelets] 01/04: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Servicebus
Posted by ac...@apache.org.
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
commit b07d90e4077313f61ee3be29b0d807b129eac7be
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 14 18:13:05 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Servicebus
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++-
.../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 2 ++
2 files changed, 4 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 ba27db67..faaa0482 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
@@ -33,7 +33,8 @@ public enum KameletPrefixSchemeEnum {
aws_sqs_batch("aws-sqs-batch","aws2-sqs"),
aws_sqs_fifo("aws-sqs-fifo","aws2-sqs"),
azure_eventhubs("azure-eventhubs","azure-eventhubs"),
- azure_functions("azure-functions","vertx-http");
+ azure_functions("azure-functions","vertx-http"),
+ azure_servicebus("azure-servicebus","azure-servicebus");
public final String label;
public final String prefix;
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 8f51c985..fcfd6dbd 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
@@ -138,5 +138,7 @@ public class KameletsCatalogTest {
assertEquals(2, headersAzureSink.size());
List<ComponentModel.EndpointHeaderModel> headersAzureFunctionsSink = catalog.getKameletSupportedHeaders("azure-functions-sink");
assertEquals(8, headersAzureFunctionsSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersAzureServicebusSource = catalog.getKameletSupportedHeaders("azure-servicebus-source");
+ assertEquals(22, headersAzureServicebusSource.size());
}
}
[camel-kamelets] 03/04: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Storage Blob Changefeed
Posted by ac...@apache.org.
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
commit 197e6fc21c45a9b293085e007455c556cd4a2773
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Fri Oct 14 18:19:10 2022 +0200
Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Azure Storage Blob Changefeed
Signed-off-by: Andrea Cosentino <an...@gmail.com>
---
.../apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 3 ++-
.../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 2 ++
2 files changed, 4 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 1e4dd166..6ad155a9 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
@@ -35,7 +35,8 @@ public enum KameletPrefixSchemeEnum {
azure_eventhubs("azure-eventhubs","azure-eventhubs"),
azure_functions("azure-functions","vertx-http"),
azure_servicebus("azure-servicebus","azure-servicebus"),
- azure_storage_blob("azure-storage-blob","azure-storage-blob");
+ azure_storage_blob("azure-storage-blob","azure-storage-blob"),
+ azure_storage_blob_changefeed("azure-storage-blob-changefeed","azure-storage-blob");
public final String label;
public final String prefix;
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 d1976cf2..6cdf5262 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
@@ -144,5 +144,7 @@ public class KameletsCatalogTest {
assertEquals(34, headersAzureStorageBlobSource.size());
List<ComponentModel.EndpointHeaderModel> headersAzureStorageBlobSink = catalog.getKameletSupportedHeaders("azure-storage-blob-sink");
assertEquals(32, headersAzureStorageBlobSink.size());
+ List<ComponentModel.EndpointHeaderModel> headersAzureStorageBlobChangeefeedSource = catalog.getKameletSupportedHeaders("azure-storage-blob-changefeed-source");
+ assertEquals(34, headersAzureStorageBlobChangeefeedSource.size());
}
}