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/17 12:19:06 UTC
[camel-kamelets] 01/05: Added a Catalog Method showing the supported headers (specific for consumer, producer and common) for a Kamelet - Google Pubsub
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 <an...@gmail.com>
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 <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 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());
}
}