This is an automated email from the ASF dual-hosted git repository. acosentino pushed a commit to branch headers-support-5 in repository https://gitbox.apache.org/repos/asf/camel-kamelets.git
commit 7a0005437b8dbcacf7e9ee9ea61457d007702d87 Author: Andrea Cosentino <[email protected]> AuthorDate: Mon Oct 17 14:04:45 2022 +0200 Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Google Pubsub Signed-off-by: Andrea Cosentino <[email protected]> --- .../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 32538294..35644c92 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 @@ -60,7 +60,8 @@ public enum KameletPrefixSchemeEnum { google_bigquery("google-bigquery", "google-bigquery"), google_calendar("google-calendar", "google-calendar-stream"), google_functions("google-functions", "google-functions"), - google_mail("google-mail", "google-mail-stream"); + google_mail("google-mail", "google-mail-stream"), + google_pubsub("google-pubsub", "google-pubsub"); public final String name; public final String scheme; 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 06d421ec..3f38ffac 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 @@ -196,5 +196,9 @@ public class KameletsCatalogTest { assertEquals(5, headersGoogleFunctionsSink.size()); List<ComponentModel.EndpointHeaderModel> headersGoogleMailSource = catalog.getKameletSupportedHeaders("google-mail-source"); assertEquals(6, headersGoogleMailSource.size()); + List<ComponentModel.EndpointHeaderModel> headersGooglePubsubSink = catalog.getKameletSupportedHeaders("google-pubsub-sink"); + assertEquals(3, headersGooglePubsubSink.size()); + List<ComponentModel.EndpointHeaderModel> headersGooglePubsubSource = catalog.getKameletSupportedHeaders("google-pubsub-source"); + assertEquals(4, headersGooglePubsubSource.size()); } }
