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 2021/08/24 05:04:12 UTC
[camel] 02/04: CAMEL-16392 - Camel-Pulsar: Make the client
configurable from component parameters
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.git
commit 75bfaf36018821e54c5cb0ec4629cfe0ddf3f3cc
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Aug 24 06:54:01 2021 +0200
CAMEL-16392 - Camel-Pulsar: Make the client configurable from component parameters
---
.../apache/camel/catalog/components/pulsar.json | 6 +
.../pulsar/PulsarComponentConfigurer.java | 18 +++
.../component/pulsar/PulsarEndpointConfigurer.java | 18 +++
.../component/pulsar/PulsarEndpointUriFactory.java | 5 +-
.../org/apache/camel/component/pulsar/pulsar.json | 6 +
.../src/main/docs/pulsar-component.adoc | 10 +-
.../dsl/PulsarComponentBuilderFactory.java | 49 ++++++++
.../endpoint/dsl/PulsarEndpointBuilderFactory.java | 138 +++++++++++++++++++++
.../modules/ROOT/pages/pulsar-component.adoc | 10 +-
9 files changed, 255 insertions(+), 5 deletions(-)
diff --git a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
index 7b8f249..81ac232 100644
--- a/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
+++ b/catalog/camel-catalog/src/generated/resources/org/apache/camel/catalog/components/pulsar.json
@@ -22,7 +22,10 @@
"lenientProperties": false
},
"componentProperties": {
+ "authenticationClass": { "kind": "property", "displayName": "Authentication Class", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "The Authentication FQCN to be used while creating the client from URI" },
+ "authenticationParams": { "kind": "property", "displayName": "Authentication Params", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "The Authentication Parameters to be used while creating the client from URI" },
"configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.pulsar.PulsarConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "Allows to pre-configure the Pulsar component with common options that the endpoints will reuse." },
+ "serviceUrl": { "kind": "property", "displayName": "Service Url", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "The Pulsar Service URL to point while creating the client from URI" },
"ackGroupTimeMillis": { "kind": "property", "displayName": "Ack Group Time Millis", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "Group the consumer acknowledgments for the specified time in milliseconds - defaults to 100" },
"ackTimeoutMillis": { "kind": "property", "displayName": "Ack Timeout Millis", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 10000, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "Timeout for unacknowledged messages in milliseconds - defaults to 10000" },
"allowManualAcknowledgement": { "kind": "property", "displayName": "Allow Manual Acknowledgement", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "Whether to allow manual message acknowledgements. If this option is ena [...]
@@ -66,6 +69,9 @@
"tenant": { "kind": "path", "displayName": "Tenant", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The tenant" },
"namespace": { "kind": "path", "displayName": "Namespace", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The namespace" },
"topic": { "kind": "path", "displayName": "Topic", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The topic" },
+ "authenticationClass": { "kind": "parameter", "displayName": "Authentication Class", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "The Authentication FQCN to be used while creating the client from URI" },
+ "authenticationParams": { "kind": "parameter", "displayName": "Authentication Params", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "The Authentication Parameters to be used while creating the client from URI" },
+ "serviceUrl": { "kind": "parameter", "displayName": "Service Url", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "The Pulsar Service URL to point while creating the client from URI" },
"ackGroupTimeMillis": { "kind": "parameter", "displayName": "Ack Group Time Millis", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "Group the consumer acknowledgments for the specified time in milliseconds - defaults [...]
"ackTimeoutMillis": { "kind": "parameter", "displayName": "Ack Timeout Millis", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 10000, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "Timeout for unacknowledged messages in milliseconds - defaults to 10000" },
"allowManualAcknowledgement": { "kind": "parameter", "displayName": "Allow Manual Acknowledgement", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "Whether to allow manual message acknowledgements. If this option [...]
diff --git a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarComponentConfigurer.java b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarComponentConfigurer.java
index 5621af9..86afa21 100644
--- a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarComponentConfigurer.java
+++ b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarComponentConfigurer.java
@@ -34,6 +34,10 @@ public class PulsarComponentConfigurer extends PropertyConfigurerSupport impleme
case "ackTimeoutMillis": getOrCreateConfiguration(target).setAckTimeoutMillis(property(camelContext, long.class, value)); return true;
case "allowmanualacknowledgement":
case "allowManualAcknowledgement": getOrCreateConfiguration(target).setAllowManualAcknowledgement(property(camelContext, boolean.class, value)); return true;
+ case "authenticationclass":
+ case "authenticationClass": getOrCreateConfiguration(target).setAuthenticationClass(property(camelContext, java.lang.String.class, value)); return true;
+ case "authenticationparams":
+ case "authenticationParams": getOrCreateConfiguration(target).setAuthenticationParams(property(camelContext, java.lang.String.class, value)); return true;
case "autoconfiguration":
case "autoConfiguration": target.setAutoConfiguration(property(camelContext, org.apache.camel.component.pulsar.utils.AutoConfiguration.class, value)); return true;
case "autowiredenabled":
@@ -93,6 +97,8 @@ public class PulsarComponentConfigurer extends PropertyConfigurerSupport impleme
case "readCompacted": getOrCreateConfiguration(target).setReadCompacted(property(camelContext, boolean.class, value)); return true;
case "sendtimeoutms":
case "sendTimeoutMs": getOrCreateConfiguration(target).setSendTimeoutMs(property(camelContext, int.class, value)); return true;
+ case "serviceurl":
+ case "serviceUrl": getOrCreateConfiguration(target).setServiceUrl(property(camelContext, java.lang.String.class, value)); return true;
case "subscriptioninitialposition":
case "subscriptionInitialPosition": getOrCreateConfiguration(target).setSubscriptionInitialPosition(property(camelContext, org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition.class, value)); return true;
case "subscriptionname":
@@ -121,6 +127,10 @@ public class PulsarComponentConfigurer extends PropertyConfigurerSupport impleme
case "ackTimeoutMillis": return long.class;
case "allowmanualacknowledgement":
case "allowManualAcknowledgement": return boolean.class;
+ case "authenticationclass":
+ case "authenticationClass": return java.lang.String.class;
+ case "authenticationparams":
+ case "authenticationParams": return java.lang.String.class;
case "autoconfiguration":
case "autoConfiguration": return org.apache.camel.component.pulsar.utils.AutoConfiguration.class;
case "autowiredenabled":
@@ -180,6 +190,8 @@ public class PulsarComponentConfigurer extends PropertyConfigurerSupport impleme
case "readCompacted": return boolean.class;
case "sendtimeoutms":
case "sendTimeoutMs": return int.class;
+ case "serviceurl":
+ case "serviceUrl": return java.lang.String.class;
case "subscriptioninitialposition":
case "subscriptionInitialPosition": return org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition.class;
case "subscriptionname":
@@ -204,6 +216,10 @@ public class PulsarComponentConfigurer extends PropertyConfigurerSupport impleme
case "ackTimeoutMillis": return getOrCreateConfiguration(target).getAckTimeoutMillis();
case "allowmanualacknowledgement":
case "allowManualAcknowledgement": return getOrCreateConfiguration(target).isAllowManualAcknowledgement();
+ case "authenticationclass":
+ case "authenticationClass": return getOrCreateConfiguration(target).getAuthenticationClass();
+ case "authenticationparams":
+ case "authenticationParams": return getOrCreateConfiguration(target).getAuthenticationParams();
case "autoconfiguration":
case "autoConfiguration": return target.getAutoConfiguration();
case "autowiredenabled":
@@ -263,6 +279,8 @@ public class PulsarComponentConfigurer extends PropertyConfigurerSupport impleme
case "readCompacted": return getOrCreateConfiguration(target).isReadCompacted();
case "sendtimeoutms":
case "sendTimeoutMs": return getOrCreateConfiguration(target).getSendTimeoutMs();
+ case "serviceurl":
+ case "serviceUrl": return getOrCreateConfiguration(target).getServiceUrl();
case "subscriptioninitialposition":
case "subscriptionInitialPosition": return getOrCreateConfiguration(target).getSubscriptionInitialPosition();
case "subscriptionname":
diff --git a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointConfigurer.java b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointConfigurer.java
index 8da9d94..f19746e 100644
--- a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointConfigurer.java
+++ b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointConfigurer.java
@@ -27,6 +27,10 @@ public class PulsarEndpointConfigurer extends PropertyConfigurerSupport implemen
case "ackTimeoutMillis": target.getPulsarConfiguration().setAckTimeoutMillis(property(camelContext, long.class, value)); return true;
case "allowmanualacknowledgement":
case "allowManualAcknowledgement": target.getPulsarConfiguration().setAllowManualAcknowledgement(property(camelContext, boolean.class, value)); return true;
+ case "authenticationclass":
+ case "authenticationClass": target.getPulsarConfiguration().setAuthenticationClass(property(camelContext, java.lang.String.class, value)); return true;
+ case "authenticationparams":
+ case "authenticationParams": target.getPulsarConfiguration().setAuthenticationParams(property(camelContext, java.lang.String.class, value)); return true;
case "batcherbuilder":
case "batcherBuilder": target.getPulsarConfiguration().setBatcherBuilder(property(camelContext, org.apache.pulsar.client.api.BatcherBuilder.class, value)); return true;
case "batchingenabled":
@@ -81,6 +85,8 @@ public class PulsarEndpointConfigurer extends PropertyConfigurerSupport implemen
case "readCompacted": target.getPulsarConfiguration().setReadCompacted(property(camelContext, boolean.class, value)); return true;
case "sendtimeoutms":
case "sendTimeoutMs": target.getPulsarConfiguration().setSendTimeoutMs(property(camelContext, int.class, value)); return true;
+ case "serviceurl":
+ case "serviceUrl": target.getPulsarConfiguration().setServiceUrl(property(camelContext, java.lang.String.class, value)); return true;
case "subscriptioninitialposition":
case "subscriptionInitialPosition": target.getPulsarConfiguration().setSubscriptionInitialPosition(property(camelContext, org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition.class, value)); return true;
case "subscriptionname":
@@ -104,6 +110,10 @@ public class PulsarEndpointConfigurer extends PropertyConfigurerSupport implemen
case "ackTimeoutMillis": return long.class;
case "allowmanualacknowledgement":
case "allowManualAcknowledgement": return boolean.class;
+ case "authenticationclass":
+ case "authenticationClass": return java.lang.String.class;
+ case "authenticationparams":
+ case "authenticationParams": return java.lang.String.class;
case "batcherbuilder":
case "batcherBuilder": return org.apache.pulsar.client.api.BatcherBuilder.class;
case "batchingenabled":
@@ -158,6 +168,8 @@ public class PulsarEndpointConfigurer extends PropertyConfigurerSupport implemen
case "readCompacted": return boolean.class;
case "sendtimeoutms":
case "sendTimeoutMs": return int.class;
+ case "serviceurl":
+ case "serviceUrl": return java.lang.String.class;
case "subscriptioninitialposition":
case "subscriptionInitialPosition": return org.apache.camel.component.pulsar.utils.consumers.SubscriptionInitialPosition.class;
case "subscriptionname":
@@ -182,6 +194,10 @@ public class PulsarEndpointConfigurer extends PropertyConfigurerSupport implemen
case "ackTimeoutMillis": return target.getPulsarConfiguration().getAckTimeoutMillis();
case "allowmanualacknowledgement":
case "allowManualAcknowledgement": return target.getPulsarConfiguration().isAllowManualAcknowledgement();
+ case "authenticationclass":
+ case "authenticationClass": return target.getPulsarConfiguration().getAuthenticationClass();
+ case "authenticationparams":
+ case "authenticationParams": return target.getPulsarConfiguration().getAuthenticationParams();
case "batcherbuilder":
case "batcherBuilder": return target.getPulsarConfiguration().getBatcherBuilder();
case "batchingenabled":
@@ -236,6 +252,8 @@ public class PulsarEndpointConfigurer extends PropertyConfigurerSupport implemen
case "readCompacted": return target.getPulsarConfiguration().isReadCompacted();
case "sendtimeoutms":
case "sendTimeoutMs": return target.getPulsarConfiguration().getSendTimeoutMs();
+ case "serviceurl":
+ case "serviceUrl": return target.getPulsarConfiguration().getServiceUrl();
case "subscriptioninitialposition":
case "subscriptionInitialPosition": return target.getPulsarConfiguration().getSubscriptionInitialPosition();
case "subscriptionname":
diff --git a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointUriFactory.java b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointUriFactory.java
index 83bf81a..0ef8c37 100644
--- a/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointUriFactory.java
+++ b/components/camel-pulsar/src/generated/java/org/apache/camel/component/pulsar/PulsarEndpointUriFactory.java
@@ -20,11 +20,12 @@ public class PulsarEndpointUriFactory extends org.apache.camel.support.component
private static final Set<String> PROPERTY_NAMES;
private static final Set<String> SECRET_PROPERTY_NAMES;
static {
- Set<String> props = new HashSet<>(39);
+ Set<String> props = new HashSet<>(42);
props.add("initialSequenceId");
props.add("numberOfConsumerThreads");
props.add("maxRedeliverCount");
props.add("messageRouter");
+ props.add("serviceUrl");
props.add("batchingMaxMessages");
props.add("compressionType");
props.add("consumerQueueSize");
@@ -44,6 +45,7 @@ public class PulsarEndpointUriFactory extends org.apache.camel.support.component
props.add("producerName");
props.add("exchangePattern");
props.add("subscriptionInitialPosition");
+ props.add("authenticationParams");
props.add("maxPendingMessages");
props.add("messageRoutingMode");
props.add("ackTimeoutMillis");
@@ -56,6 +58,7 @@ public class PulsarEndpointUriFactory extends org.apache.camel.support.component
props.add("persistence");
props.add("topic");
props.add("messageListener");
+ props.add("authenticationClass");
props.add("exceptionHandler");
props.add("deadLetterTopic");
props.add("allowManualAcknowledgement");
diff --git a/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json b/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json
index 7b8f249..81ac232 100644
--- a/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json
+++ b/components/camel-pulsar/src/generated/resources/org/apache/camel/component/pulsar/pulsar.json
@@ -22,7 +22,10 @@
"lenientProperties": false
},
"componentProperties": {
+ "authenticationClass": { "kind": "property", "displayName": "Authentication Class", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "The Authentication FQCN to be used while creating the client from URI" },
+ "authenticationParams": { "kind": "property", "displayName": "Authentication Params", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "The Authentication Parameters to be used while creating the client from URI" },
"configuration": { "kind": "property", "displayName": "Configuration", "group": "common", "label": "", "required": false, "type": "object", "javaType": "org.apache.camel.component.pulsar.PulsarConfiguration", "deprecated": false, "autowired": false, "secret": false, "description": "Allows to pre-configure the Pulsar component with common options that the endpoints will reuse." },
+ "serviceUrl": { "kind": "property", "displayName": "Service Url", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "The Pulsar Service URL to point while creating the client from URI" },
"ackGroupTimeMillis": { "kind": "property", "displayName": "Ack Group Time Millis", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "Group the consumer acknowledgments for the specified time in milliseconds - defaults to 100" },
"ackTimeoutMillis": { "kind": "property", "displayName": "Ack Timeout Millis", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 10000, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "Timeout for unacknowledged messages in milliseconds - defaults to 10000" },
"allowManualAcknowledgement": { "kind": "property", "displayName": "Allow Manual Acknowledgement", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "configuration", "description": "Whether to allow manual message acknowledgements. If this option is ena [...]
@@ -66,6 +69,9 @@
"tenant": { "kind": "path", "displayName": "Tenant", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The tenant" },
"namespace": { "kind": "path", "displayName": "Namespace", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The namespace" },
"topic": { "kind": "path", "displayName": "Topic", "group": "common", "label": "", "required": true, "type": "string", "javaType": "java.lang.String", "deprecated": false, "deprecationNote": "", "autowired": false, "secret": false, "description": "The topic" },
+ "authenticationClass": { "kind": "parameter", "displayName": "Authentication Class", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "The Authentication FQCN to be used while creating the client from URI" },
+ "authenticationParams": { "kind": "parameter", "displayName": "Authentication Params", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "The Authentication Parameters to be used while creating the client from URI" },
+ "serviceUrl": { "kind": "parameter", "displayName": "Service Url", "group": "common", "label": "common", "required": false, "type": "string", "javaType": "java.lang.String", "deprecated": false, "autowired": false, "secret": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "The Pulsar Service URL to point while creating the client from URI" },
"ackGroupTimeMillis": { "kind": "parameter", "displayName": "Ack Group Time Millis", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 100, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "Group the consumer acknowledgments for the specified time in milliseconds - defaults [...]
"ackTimeoutMillis": { "kind": "parameter", "displayName": "Ack Timeout Millis", "group": "consumer", "label": "consumer", "required": false, "type": "integer", "javaType": "long", "deprecated": false, "autowired": false, "secret": false, "defaultValue": 10000, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "Timeout for unacknowledged messages in milliseconds - defaults to 10000" },
"allowManualAcknowledgement": { "kind": "parameter", "displayName": "Allow Manual Acknowledgement", "group": "consumer", "label": "consumer", "required": false, "type": "boolean", "javaType": "boolean", "deprecated": false, "autowired": false, "secret": false, "defaultValue": false, "configurationClass": "org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField": "pulsarConfiguration", "description": "Whether to allow manual message acknowledgements. If this option [...]
diff --git a/components/camel-pulsar/src/main/docs/pulsar-component.adoc b/components/camel-pulsar/src/main/docs/pulsar-component.adoc
index c0df243..a891626 100644
--- a/components/camel-pulsar/src/main/docs/pulsar-component.adoc
+++ b/components/camel-pulsar/src/main/docs/pulsar-component.adoc
@@ -70,14 +70,17 @@ The following two sections lists all the options, firstly for the component foll
== Component Options
-The Pulsar component supports 38 options, which are listed below.
+The Pulsar component supports 41 options, which are listed below.
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *authenticationClass* (common) | The Authentication FQCN to be used while creating the client from URI | | String
+| *authenticationParams* (common) | The Authentication Parameters to be used while creating the client from URI | | String
| *configuration* (common) | Allows to pre-configure the Pulsar component with common options that the endpoints will reuse. | | PulsarConfiguration
+| *serviceUrl* (common) | The Pulsar Service URL to point while creating the client from URI | | String
| *ackGroupTimeMillis* (consumer) | Group the consumer acknowledgments for the specified time in milliseconds - defaults to 100 | 100 | long
| *ackTimeoutMillis* (consumer) | Timeout for unacknowledged messages in milliseconds - defaults to 10000 | 10000 | long
| *allowManualAcknowledgement* (consumer) | Whether to allow manual message acknowledgements. If this option is enabled, then messages are not acknowledged automatically after successful route completion. Instead, an instance of PulsarMessageReceipt is stored as a header on the org.apache.camel.Exchange. Messages can then be acknowledged using PulsarMessageReceipt at any time before the ackTimeout occurs. | false | boolean
@@ -142,12 +145,15 @@ with the following path and query parameters:
|===
-=== Query Parameters (35 parameters):
+=== Query Parameters (38 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *authenticationClass* (common) | The Authentication FQCN to be used while creating the client from URI | | String
+| *authenticationParams* (common) | The Authentication Parameters to be used while creating the client from URI | | String
+| *serviceUrl* (common) | The Pulsar Service URL to point while creating the client from URI | | String
| *ackGroupTimeMillis* (consumer) | Group the consumer acknowledgments for the specified time in milliseconds - defaults to 100 | 100 | long
| *ackTimeoutMillis* (consumer) | Timeout for unacknowledged messages in milliseconds - defaults to 10000 | 10000 | long
| *allowManualAcknowledgement* (consumer) | Whether to allow manual message acknowledgements. If this option is enabled, then messages are not acknowledged automatically after successful route completion. Instead, an instance of PulsarMessageReceipt is stored as a header on the org.apache.camel.Exchange. Messages can then be acknowledged using PulsarMessageReceipt at any time before the ackTimeout occurs. | false | boolean
diff --git a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
index 826cf1f..73c1dfd 100644
--- a/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
+++ b/core/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
@@ -51,6 +51,38 @@ public interface PulsarComponentBuilderFactory {
extends
ComponentBuilder<PulsarComponent> {
/**
+ * The Authentication FQCN to be used while creating the client from
+ * URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param authenticationClass the value to set
+ * @return the dsl builder
+ */
+ default PulsarComponentBuilder authenticationClass(
+ java.lang.String authenticationClass) {
+ doSetProperty("authenticationClass", authenticationClass);
+ return this;
+ }
+ /**
+ * The Authentication Parameters to be used while creating the client
+ * from URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param authenticationParams the value to set
+ * @return the dsl builder
+ */
+ default PulsarComponentBuilder authenticationParams(
+ java.lang.String authenticationParams) {
+ doSetProperty("authenticationParams", authenticationParams);
+ return this;
+ }
+ /**
* Allows to pre-configure the Pulsar component with common options that
* the endpoints will reuse.
*
@@ -68,6 +100,20 @@ public interface PulsarComponentBuilderFactory {
return this;
}
/**
+ * The Pulsar Service URL to point while creating the client from URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param serviceUrl the value to set
+ * @return the dsl builder
+ */
+ default PulsarComponentBuilder serviceUrl(java.lang.String serviceUrl) {
+ doSetProperty("serviceUrl", serviceUrl);
+ return this;
+ }
+ /**
* Group the consumer acknowledgments for the specified time in
* milliseconds - defaults to 100.
*
@@ -726,7 +772,10 @@ public interface PulsarComponentBuilderFactory {
String name,
Object value) {
switch (name) {
+ case "authenticationClass": getOrCreateConfiguration((PulsarComponent) component).setAuthenticationClass((java.lang.String) value); return true;
+ case "authenticationParams": getOrCreateConfiguration((PulsarComponent) component).setAuthenticationParams((java.lang.String) value); return true;
case "configuration": ((PulsarComponent) component).setConfiguration((org.apache.camel.component.pulsar.PulsarConfiguration) value); return true;
+ case "serviceUrl": getOrCreateConfiguration((PulsarComponent) component).setServiceUrl((java.lang.String) value); return true;
case "ackGroupTimeMillis": getOrCreateConfiguration((PulsarComponent) component).setAckGroupTimeMillis((long) value); return true;
case "ackTimeoutMillis": getOrCreateConfiguration((PulsarComponent) component).setAckTimeoutMillis((long) value); return true;
case "allowManualAcknowledgement": getOrCreateConfiguration((PulsarComponent) component).setAllowManualAcknowledgement((boolean) value); return true;
diff --git a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
index 4c509fe..5dd0582 100644
--- a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
+++ b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
@@ -42,6 +42,52 @@ public interface PulsarEndpointBuilderFactory {
return (AdvancedPulsarEndpointConsumerBuilder) this;
}
/**
+ * The Authentication FQCN to be used while creating the client from
+ * URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param authenticationClass the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointConsumerBuilder authenticationClass(
+ String authenticationClass) {
+ doSetProperty("authenticationClass", authenticationClass);
+ return this;
+ }
+ /**
+ * The Authentication Parameters to be used while creating the client
+ * from URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param authenticationParams the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointConsumerBuilder authenticationParams(
+ String authenticationParams) {
+ doSetProperty("authenticationParams", authenticationParams);
+ return this;
+ }
+ /**
+ * The Pulsar Service URL to point while creating the client from URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param serviceUrl the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointConsumerBuilder serviceUrl(String serviceUrl) {
+ doSetProperty("serviceUrl", serviceUrl);
+ return this;
+ }
+ /**
* Group the consumer acknowledgments for the specified time in
* milliseconds - defaults to 100.
*
@@ -731,6 +777,52 @@ public interface PulsarEndpointBuilderFactory {
return (AdvancedPulsarEndpointProducerBuilder) this;
}
/**
+ * The Authentication FQCN to be used while creating the client from
+ * URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param authenticationClass the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointProducerBuilder authenticationClass(
+ String authenticationClass) {
+ doSetProperty("authenticationClass", authenticationClass);
+ return this;
+ }
+ /**
+ * The Authentication Parameters to be used while creating the client
+ * from URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param authenticationParams the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointProducerBuilder authenticationParams(
+ String authenticationParams) {
+ doSetProperty("authenticationParams", authenticationParams);
+ return this;
+ }
+ /**
+ * The Pulsar Service URL to point while creating the client from URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param serviceUrl the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointProducerBuilder serviceUrl(String serviceUrl) {
+ doSetProperty("serviceUrl", serviceUrl);
+ return this;
+ }
+ /**
* Control batching method used by the producer.
*
* The option is a:
@@ -1227,6 +1319,52 @@ public interface PulsarEndpointBuilderFactory {
default AdvancedPulsarEndpointBuilder advanced() {
return (AdvancedPulsarEndpointBuilder) this;
}
+ /**
+ * The Authentication FQCN to be used while creating the client from
+ * URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param authenticationClass the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointBuilder authenticationClass(
+ String authenticationClass) {
+ doSetProperty("authenticationClass", authenticationClass);
+ return this;
+ }
+ /**
+ * The Authentication Parameters to be used while creating the client
+ * from URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param authenticationParams the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointBuilder authenticationParams(
+ String authenticationParams) {
+ doSetProperty("authenticationParams", authenticationParams);
+ return this;
+ }
+ /**
+ * The Pulsar Service URL to point while creating the client from URI.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param serviceUrl the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointBuilder serviceUrl(String serviceUrl) {
+ doSetProperty("serviceUrl", serviceUrl);
+ return this;
+ }
}
/**
diff --git a/docs/components/modules/ROOT/pages/pulsar-component.adoc b/docs/components/modules/ROOT/pages/pulsar-component.adoc
index 504a336..69e4bd8 100644
--- a/docs/components/modules/ROOT/pages/pulsar-component.adoc
+++ b/docs/components/modules/ROOT/pages/pulsar-component.adoc
@@ -72,14 +72,17 @@ The following two sections lists all the options, firstly for the component foll
== Component Options
-The Pulsar component supports 38 options, which are listed below.
+The Pulsar component supports 41 options, which are listed below.
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *authenticationClass* (common) | The Authentication FQCN to be used while creating the client from URI | | String
+| *authenticationParams* (common) | The Authentication Parameters to be used while creating the client from URI | | String
| *configuration* (common) | Allows to pre-configure the Pulsar component with common options that the endpoints will reuse. | | PulsarConfiguration
+| *serviceUrl* (common) | The Pulsar Service URL to point while creating the client from URI | | String
| *ackGroupTimeMillis* (consumer) | Group the consumer acknowledgments for the specified time in milliseconds - defaults to 100 | 100 | long
| *ackTimeoutMillis* (consumer) | Timeout for unacknowledged messages in milliseconds - defaults to 10000 | 10000 | long
| *allowManualAcknowledgement* (consumer) | Whether to allow manual message acknowledgements. If this option is enabled, then messages are not acknowledged automatically after successful route completion. Instead, an instance of PulsarMessageReceipt is stored as a header on the org.apache.camel.Exchange. Messages can then be acknowledged using PulsarMessageReceipt at any time before the ackTimeout occurs. | false | boolean
@@ -144,12 +147,15 @@ with the following path and query parameters:
|===
-=== Query Parameters (35 parameters):
+=== Query Parameters (38 parameters):
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
+| *authenticationClass* (common) | The Authentication FQCN to be used while creating the client from URI | | String
+| *authenticationParams* (common) | The Authentication Parameters to be used while creating the client from URI | | String
+| *serviceUrl* (common) | The Pulsar Service URL to point while creating the client from URI | | String
| *ackGroupTimeMillis* (consumer) | Group the consumer acknowledgments for the specified time in milliseconds - defaults to 100 | 100 | long
| *ackTimeoutMillis* (consumer) | Timeout for unacknowledged messages in milliseconds - defaults to 10000 | 10000 | long
| *allowManualAcknowledgement* (consumer) | Whether to allow manual message acknowledgements. If this option is enabled, then messages are not acknowledged automatically after successful route completion. Instead, an instance of PulsarMessageReceipt is stored as a header on the org.apache.camel.Exchange. Messages can then be acknowledged using PulsarMessageReceipt at any time before the ackTimeout occurs. | false | boolean