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:10 UTC
[camel] branch main updated (e6099e9 -> d054230)
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.git.
from e6099e9 Regen
new e119b98 CAMEL-16392 - Camel-Pulsar: Make the client configurable from component parameters
new 75bfaf3 CAMEL-16392 - Camel-Pulsar: Make the client configurable from component parameters
new 351e3bc Revert "Upgrade Optaplanner to version 8.10.0.Final"
new d054230 Sync deps
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:
camel-dependencies/pom.xml | 2 +-
.../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 +-
.../component/pulsar/PulsarConfiguration.java | 39 ++++++
.../camel/component/pulsar/PulsarEndpoint.java | 14 ++-
.../dsl/PulsarComponentBuilderFactory.java | 49 ++++++++
.../endpoint/dsl/PulsarEndpointBuilderFactory.java | 138 +++++++++++++++++++++
.../modules/ROOT/pages/pulsar-component.adoc | 10 +-
parent/pom.xml | 2 +-
13 files changed, 309 insertions(+), 8 deletions(-)
[camel] 02/04: CAMEL-16392 - Camel-Pulsar: Make the client
configurable from component parameters
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.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
[camel] 01/04: CAMEL-16392 - Camel-Pulsar: Make the client
configurable from component parameters
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.git
commit e119b98ee928d23ddc790f1f4c50a218c03d6418
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Mon Aug 23 16:37:44 2021 +0200
CAMEL-16392 - Camel-Pulsar: Make the client configurable from component parameters
---
.../component/pulsar/PulsarConfiguration.java | 39 ++++++++++++++++++++++
.../camel/component/pulsar/PulsarEndpoint.java | 14 +++++++-
2 files changed, 52 insertions(+), 1 deletion(-)
diff --git a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
index cceb811..5f22892 100644
--- a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
+++ b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarConfiguration.java
@@ -35,6 +35,12 @@ import static org.apache.camel.component.pulsar.utils.consumers.SubscriptionType
@UriParams
public class PulsarConfiguration implements Cloneable {
+ @UriParam(label = "common")
+ private String serviceUrl;
+ @UriParam(label = "common")
+ private String authenticationClass;
+ @UriParam(label = "common")
+ private String authenticationParams;
@UriParam(label = "consumer")
private boolean topicsPattern;
@UriParam(label = "consumer", defaultValue = "PersistentOnly")
@@ -483,4 +489,37 @@ public class PulsarConfiguration implements Cloneable {
public void setNumberOfConsumerThreads(int numberOfConsumerThreads) {
this.numberOfConsumerThreads = numberOfConsumerThreads;
}
+
+ public String getServiceUrl() {
+ return serviceUrl;
+ }
+
+ /**
+ * The Pulsar Service URL to point while creating the client from URI
+ */
+ public void setServiceUrl(String serviceUrl) {
+ this.serviceUrl = serviceUrl;
+ }
+
+ public String getAuthenticationClass() {
+ return authenticationClass;
+ }
+
+ /**
+ * The Authentication FQCN to be used while creating the client from URI
+ */
+ public void setAuthenticationClass(String authenticationClass) {
+ this.authenticationClass = authenticationClass;
+ }
+
+ public String getAuthenticationParams() {
+ return authenticationParams;
+ }
+
+ /**
+ * The Authentication Parameters to be used while creating the client from URI
+ */
+ public void setAuthenticationParams(String authenticationParams) {
+ this.authenticationParams = authenticationParams;
+ }
}
diff --git a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
index e8f48f5..ceba2ef 100644
--- a/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
+++ b/components/camel-pulsar/src/main/java/org/apache/camel/component/pulsar/PulsarEndpoint.java
@@ -26,6 +26,7 @@ import org.apache.camel.spi.UriParam;
import org.apache.camel.spi.UriPath;
import org.apache.camel.support.DefaultEndpoint;
import org.apache.camel.util.ObjectHelper;
+import org.apache.pulsar.client.api.ClientBuilder;
import org.apache.pulsar.client.api.PulsarClient;
/**
@@ -151,7 +152,18 @@ public class PulsarEndpoint extends DefaultEndpoint {
@Override
protected void doStart() throws Exception {
- ObjectHelper.notNull(pulsarClient, "pulsarClient", this);
+ if (ObjectHelper.isEmpty(pulsarClient)) {
+ ClientBuilder builder = PulsarClient.builder();
+ if (ObjectHelper.isNotEmpty(pulsarConfiguration.getServiceUrl())) {
+ builder = builder.serviceUrl(pulsarConfiguration.getServiceUrl());
+ }
+ if (ObjectHelper.isNotEmpty(pulsarConfiguration.getAuthenticationClass())
+ && ObjectHelper.isNotEmpty(pulsarConfiguration.getAuthenticationParams())) {
+ builder = builder.authentication(pulsarConfiguration.getAuthenticationClass(),
+ pulsarConfiguration.getAuthenticationParams());
+ }
+ pulsarClient = builder.build();
+ }
}
@Override
[camel] 04/04: Sync deps
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.git
commit d054230d23f90f8328e72c78a73f36ea028a8e45
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Aug 24 07:03:35 2021 +0200
Sync deps
---
camel-dependencies/pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/camel-dependencies/pom.xml b/camel-dependencies/pom.xml
index b690235..97a1a97 100644
--- a/camel-dependencies/pom.xml
+++ b/camel-dependencies/pom.xml
@@ -445,7 +445,7 @@
<opentracing-version>0.33.0</opentracing-version>
<openwebbeans-version>1.7.3</openwebbeans-version>
<openwebbeans1-version>1.2.7</openwebbeans1-version>
- <optaplanner-version>8.10.0.Final</optaplanner-version>
+ <optaplanner-version>8.9.1.Final</optaplanner-version>
<os-maven-plugin-version>1.7.0</os-maven-plugin-version>
<paho-version>1.2.5</paho-version>
<partial-build-plugin-version>2.7</partial-build-plugin-version>
[camel] 03/04: Revert "Upgrade Optaplanner to version 8.10.0.Final"
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.git
commit 351e3bc74d4a5a7724a4da6224395f30d4ce9d28
Author: Andrea Cosentino <an...@gmail.com>
AuthorDate: Tue Aug 24 06:54:29 2021 +0200
Revert "Upgrade Optaplanner to version 8.10.0.Final"
This reverts commit e67bdbffd94ea1196dbed1fb414b58702de3e8ab.
---
parent/pom.xml | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/parent/pom.xml b/parent/pom.xml
index c9a14f6..0d1d303 100644
--- a/parent/pom.xml
+++ b/parent/pom.xml
@@ -431,7 +431,7 @@
<opentelemetry-alpha-version>${opentelemetry-version}-alpha</opentelemetry-alpha-version>
<opentracing-version>0.33.0</opentracing-version>
<opentracing-tracerresolver-version>0.1.8</opentracing-tracerresolver-version>
- <optaplanner-version>8.10.0.Final</optaplanner-version>
+ <optaplanner-version>8.9.1.Final</optaplanner-version>
<os-maven-plugin-version>1.7.0</os-maven-plugin-version>
<paho-version>1.2.5</paho-version>
<partial-build-plugin-version>2.7</partial-build-plugin-version>