This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch more-headers-support in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 840b19c8c36a4519fd739d21c88e41748d425eae Author: Andrea Cosentino <[email protected]> AuthorDate: Mon Oct 17 10:00:07 2022 +0200 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Elasticsearch Rest Signed-off-by: Andrea Cosentino <[email protected]> --- .../apache/camel/kamelets/catalog/model/KameletPrefixSchemeEnum.java | 4 +++- .../java/org/apache/camel/kamelets/catalog/KameletsCatalogTest.java | 4 ++++ 2 files changed, 7 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 81eb7224..847c2515 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 @@ -44,7 +44,9 @@ public enum KameletPrefixSchemeEnum { ceph("ceph", "aws2-s3"), chuck_norris("chuck-norris", "http"), couchbase("couchbase", "couchbase"), - dropbox("dropbox", "dropbox"); + dropbox("dropbox", "dropbox"), + elasticsearch_rest_index("elasticsearch-index", "elasticsearch-rest"), + elasticsearch_rest_search("elasticsearch-search", "elasticsearch-rest"); 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 ef44dafc..321d239d 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 @@ -160,5 +160,9 @@ public class KameletsCatalogTest { assertEquals(0, headersDropboxSource.size()); List<ComponentModel.EndpointHeaderModel> headersDropboxSink = catalog.getKameletSupportedHeaders("dropbox-source"); assertEquals(0, headersDropboxSink.size()); + List<ComponentModel.EndpointHeaderModel> headersESIndexSink = catalog.getKameletSupportedHeaders("elasticsearch-index-sink"); + assertEquals(8, headersESIndexSink.size()); + List<ComponentModel.EndpointHeaderModel> headersESSearchSource = catalog.getKameletSupportedHeaders("elasticsearch-search-source"); + assertEquals(8, headersESSearchSource.size()); } }
