This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/main by this push:
new a025e39b383 Regen
a025e39b383 is described below
commit a025e39b3839766aa28f95821783910cd23e04d6
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Sat Aug 13 11:01:13 2022 +0200
Regen
---
.../apache/camel/catalog/components/pulsar.json | 4 ++
.../dsl/PulsarComponentBuilderFactory.java | 34 ++++++++++++
.../endpoint/dsl/PulsarEndpointBuilderFactory.java | 64 ++++++++++++++++++++++
3 files changed, 102 insertions(+)
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 c28d2bb37a1..d2302601763 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
@@ -28,6 +28,7 @@
"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" },
+ "ackTimeoutRedeliveryBackoff": { "kind": "property", "displayName": "Ack
Timeout Redelivery Backoff", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RedeliveryBackoff", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "RedeliveryBackoff to use for ack timeout
redelivery b [...]
"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 [...]
"bridgeErrorHandler": { "kind": "property", "displayName": "Bridge Error
Handler", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Allows for bridging the
consumer to the Camel routing Error Handler, which mean any exceptions occurred
while the consumer is trying to pickup incoming messages, or the likes, will
now be processed as a me [...]
"consumerName": { "kind": "property", "displayName": "Consumer Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "sole-consumer", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Name of the consumer when subscription is
EXCLUSIVE" },
@@ -36,6 +37,7 @@
"deadLetterTopic": { "kind": "property", "displayName": "Dead Letter
Topic", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Name of the topic where the messages which
fail maxRedeliverCount times will be sent. Note: if not set, defa [...]
"maxRedeliverCount": { "kind": "property", "displayName": "Max Redeliver
Count", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Maximum number of times that a message will be
redelivered before being sent to the dead letter queue. [...]
"messageListener": { "kind": "property", "displayName": "Message
Listener", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Whether to use the messageListener interface,
or to receive messages using a separate thread pool" },
+ "negativeAckRedeliveryBackoff": { "kind": "property", "displayName":
"Negative Ack Redelivery Backoff", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RedeliveryBackoff", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "RedeliveryBackoff to use for negative ack
redeliver [...]
"negativeAckRedeliveryDelayMicros": { "kind": "property", "displayName":
"Negative Ack Redelivery Delay Micros", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Set the negative acknowledgement delay" },
"numberOfConsumers": { "kind": "property", "displayName": "Number Of
Consumers", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Number of consumers - defaults to 1" },
"numberOfConsumerThreads": { "kind": "property", "displayName": "Number Of
Consumer Threads", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"configuration", "description": "Number of threads to receive and handle
messages when using a separate thread pool" },
@@ -90,6 +92,7 @@
"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" },
+ "ackTimeoutRedeliveryBackoff": { "kind": "parameter", "displayName": "Ack
Timeout Redelivery Backoff", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RedeliveryBackoff", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "RedeliveryBackoff to use for ack timeout
redel [...]
"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 [...]
"consumerName": { "kind": "parameter", "displayName": "Consumer Name",
"group": "consumer", "label": "consumer", "required": false, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": "sole-consumer", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Name of the consumer when subscription
is EXCLUSIVE" },
"consumerNamePrefix": { "kind": "parameter", "displayName": "Consumer Name
Prefix", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "cons", "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Prefix to add to consumer names when a
SHARED or FAILOVER subscription [...]
@@ -97,6 +100,7 @@
"deadLetterTopic": { "kind": "parameter", "displayName": "Dead Letter
Topic", "group": "consumer", "label": "consumer", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Name of the topic where the messages
which fail maxRedeliverCount times will be sent. Note: if not se [...]
"maxRedeliverCount": { "kind": "parameter", "displayName": "Max Redeliver
Count", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Maximum number of times that a message
will be redelivered before being sent to the dead letter [...]
"messageListener": { "kind": "parameter", "displayName": "Message
Listener", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": true, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Whether to use the messageListener
interface, or to receive messages using a separate th [...]
+ "negativeAckRedeliveryBackoff": { "kind": "parameter", "displayName":
"Negative Ack Redelivery Backoff", "group": "consumer", "label": "consumer",
"required": false, "type": "object", "javaType":
"org.apache.pulsar.client.api.RedeliveryBackoff", "deprecated": false,
"autowired": false, "secret": false, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "RedeliveryBackoff to use for negative
ack re [...]
"negativeAckRedeliveryDelayMicros": { "kind": "parameter", "displayName":
"Negative Ack Redelivery Delay Micros", "group": "consumer", "label":
"consumer", "required": false, "type": "integer", "javaType": "long",
"deprecated": false, "autowired": false, "secret": false, "defaultValue":
60000000, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Set the negative acknowledgement delay"
},
"numberOfConsumers": { "kind": "parameter", "displayName": "Number Of
Consumers", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Number of consumers - defaults to 1" },
"numberOfConsumerThreads": { "kind": "parameter", "displayName": "Number
Of Consumer Threads", "group": "consumer", "label": "consumer", "required":
false, "type": "integer", "javaType": "int", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": 1, "configurationClass":
"org.apache.camel.component.pulsar.PulsarConfiguration", "configurationField":
"pulsarConfiguration", "description": "Number of threads to receive and handle
messages when using a separate thread [...]
diff --git
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
index 73c1dfdab27..bbf45a8973a 100644
---
a/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
+++
b/dsl/camel-componentdsl/src/generated/java/org/apache/camel/builder/component/dsl/PulsarComponentBuilderFactory.java
@@ -146,6 +146,22 @@ public interface PulsarComponentBuilderFactory {
doSetProperty("ackTimeoutMillis", ackTimeoutMillis);
return this;
}
+ /**
+ * RedeliveryBackoff to use for ack timeout redelivery backoff.
+ *
+ * The option is a:
+ *
<code>org.apache.pulsar.client.api.RedeliveryBackoff</code> type.
+ *
+ * Group: consumer
+ *
+ * @param ackTimeoutRedeliveryBackoff the value to set
+ * @return the dsl builder
+ */
+ default PulsarComponentBuilder ackTimeoutRedeliveryBackoff(
+ org.apache.pulsar.client.api.RedeliveryBackoff
ackTimeoutRedeliveryBackoff) {
+ doSetProperty("ackTimeoutRedeliveryBackoff",
ackTimeoutRedeliveryBackoff);
+ return this;
+ }
/**
* Whether to allow manual message acknowledgements. If this option is
* enabled, then messages are not acknowledged automatically after
@@ -287,6 +303,22 @@ public interface PulsarComponentBuilderFactory {
doSetProperty("messageListener", messageListener);
return this;
}
+ /**
+ * RedeliveryBackoff to use for negative ack redelivery backoff.
+ *
+ * The option is a:
+ *
<code>org.apache.pulsar.client.api.RedeliveryBackoff</code> type.
+ *
+ * Group: consumer
+ *
+ * @param negativeAckRedeliveryBackoff the value to set
+ * @return the dsl builder
+ */
+ default PulsarComponentBuilder negativeAckRedeliveryBackoff(
+ org.apache.pulsar.client.api.RedeliveryBackoff
negativeAckRedeliveryBackoff) {
+ doSetProperty("negativeAckRedeliveryBackoff",
negativeAckRedeliveryBackoff);
+ return this;
+ }
/**
* Set the negative acknowledgement delay.
*
@@ -778,6 +810,7 @@ public interface PulsarComponentBuilderFactory {
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 "ackTimeoutRedeliveryBackoff":
getOrCreateConfiguration((PulsarComponent)
component).setAckTimeoutRedeliveryBackoff((org.apache.pulsar.client.api.RedeliveryBackoff)
value); return true;
case "allowManualAcknowledgement":
getOrCreateConfiguration((PulsarComponent)
component).setAllowManualAcknowledgement((boolean) value); return true;
case "bridgeErrorHandler": ((PulsarComponent)
component).setBridgeErrorHandler((boolean) value); return true;
case "consumerName": getOrCreateConfiguration((PulsarComponent)
component).setConsumerName((java.lang.String) value); return true;
@@ -786,6 +819,7 @@ public interface PulsarComponentBuilderFactory {
case "deadLetterTopic": getOrCreateConfiguration((PulsarComponent)
component).setDeadLetterTopic((java.lang.String) value); return true;
case "maxRedeliverCount":
getOrCreateConfiguration((PulsarComponent)
component).setMaxRedeliverCount((java.lang.Integer) value); return true;
case "messageListener": getOrCreateConfiguration((PulsarComponent)
component).setMessageListener((boolean) value); return true;
+ case "negativeAckRedeliveryBackoff":
getOrCreateConfiguration((PulsarComponent)
component).setNegativeAckRedeliveryBackoff((org.apache.pulsar.client.api.RedeliveryBackoff)
value); return true;
case "negativeAckRedeliveryDelayMicros":
getOrCreateConfiguration((PulsarComponent)
component).setNegativeAckRedeliveryDelayMicros((long) value); return true;
case "numberOfConsumers":
getOrCreateConfiguration((PulsarComponent)
component).setNumberOfConsumers((int) value); return true;
case "numberOfConsumerThreads":
getOrCreateConfiguration((PulsarComponent)
component).setNumberOfConsumerThreads((int) value); return true;
diff --git
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
index 75e79256580..e8e1dd42c69 100644
---
a/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
+++
b/dsl/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/PulsarEndpointBuilderFactory.java
@@ -157,6 +157,38 @@ public interface PulsarEndpointBuilderFactory {
doSetProperty("ackTimeoutMillis", ackTimeoutMillis);
return this;
}
+ /**
+ * RedeliveryBackoff to use for ack timeout redelivery backoff.
+ *
+ * The option is a:
+ *
<code>org.apache.pulsar.client.api.RedeliveryBackoff</code> type.
+ *
+ * Group: consumer
+ *
+ * @param ackTimeoutRedeliveryBackoff the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointConsumerBuilder ackTimeoutRedeliveryBackoff(
+ org.apache.pulsar.client.api.RedeliveryBackoff
ackTimeoutRedeliveryBackoff) {
+ doSetProperty("ackTimeoutRedeliveryBackoff",
ackTimeoutRedeliveryBackoff);
+ return this;
+ }
+ /**
+ * RedeliveryBackoff to use for ack timeout redelivery backoff.
+ *
+ * The option will be converted to a
+ *
<code>org.apache.pulsar.client.api.RedeliveryBackoff</code> type.
+ *
+ * Group: consumer
+ *
+ * @param ackTimeoutRedeliveryBackoff the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointConsumerBuilder ackTimeoutRedeliveryBackoff(
+ String ackTimeoutRedeliveryBackoff) {
+ doSetProperty("ackTimeoutRedeliveryBackoff",
ackTimeoutRedeliveryBackoff);
+ return this;
+ }
/**
* Whether to allow manual message acknowledgements. If this option is
* enabled, then messages are not acknowledged automatically after
@@ -351,6 +383,38 @@ public interface PulsarEndpointBuilderFactory {
doSetProperty("messageListener", messageListener);
return this;
}
+ /**
+ * RedeliveryBackoff to use for negative ack redelivery backoff.
+ *
+ * The option is a:
+ *
<code>org.apache.pulsar.client.api.RedeliveryBackoff</code> type.
+ *
+ * Group: consumer
+ *
+ * @param negativeAckRedeliveryBackoff the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointConsumerBuilder negativeAckRedeliveryBackoff(
+ org.apache.pulsar.client.api.RedeliveryBackoff
negativeAckRedeliveryBackoff) {
+ doSetProperty("negativeAckRedeliveryBackoff",
negativeAckRedeliveryBackoff);
+ return this;
+ }
+ /**
+ * RedeliveryBackoff to use for negative ack redelivery backoff.
+ *
+ * The option will be converted to a
+ *
<code>org.apache.pulsar.client.api.RedeliveryBackoff</code> type.
+ *
+ * Group: consumer
+ *
+ * @param negativeAckRedeliveryBackoff the value to set
+ * @return the dsl builder
+ */
+ default PulsarEndpointConsumerBuilder negativeAckRedeliveryBackoff(
+ String negativeAckRedeliveryBackoff) {
+ doSetProperty("negativeAckRedeliveryBackoff",
negativeAckRedeliveryBackoff);
+ return this;
+ }
/**
* Set the negative acknowledgement delay.
*
