This is an automated email from the ASF dual-hosted git repository.
davsclaus pushed a commit to branch camel-3.18.x
in repository https://gitbox.apache.org/repos/asf/camel.git
commit 40b5c56a1f95e84c7bb4ab4bf1ed7f0dd9f9eb2d
Author: Claus Ibsen <claus.ib...@gmail.com>
AuthorDate: Tue Sep 13 19:49:26 2022 +0200
CAMEL-18503: Configure max ack extension period in PubSub subscriber (#8363)
---
.../component/google/pubsub/GooglePubsubEndpointConfigurer.java | 6 ++++++
.../component/google/pubsub/GooglePubsubEndpointUriFactory.java | 3 ++-
.../org/apache/camel/component/google/pubsub/google-pubsub.json | 1 +
3 files changed, 9 insertions(+), 1 deletion(-)
diff --git
a/components/camel-google/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointConfigurer.java
b/components/camel-google/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointConfigurer.java
index 0e8211c1cb0..634fd267887 100644
---
a/components/camel-google/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointConfigurer.java
+++
b/components/camel-google/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointConfigurer.java
@@ -36,6 +36,8 @@ public class GooglePubsubEndpointConfigurer extends
PropertyConfigurerSupport im
case "lazyStartProducer":
target.setLazyStartProducer(property(camelContext, boolean.class, value));
return true;
case "loggerid":
case "loggerId": target.setLoggerId(property(camelContext,
java.lang.String.class, value)); return true;
+ case "maxackextensionperiod":
+ case "maxAckExtensionPeriod":
target.setMaxAckExtensionPeriod(property(camelContext, int.class, value));
return true;
case "maxmessagesperpoll":
case "maxMessagesPerPoll":
target.setMaxMessagesPerPoll(property(camelContext, java.lang.Integer.class,
value)); return true;
case "messageorderingenabled":
@@ -74,6 +76,8 @@ public class GooglePubsubEndpointConfigurer extends
PropertyConfigurerSupport im
case "lazyStartProducer": return boolean.class;
case "loggerid":
case "loggerId": return java.lang.String.class;
+ case "maxackextensionperiod":
+ case "maxAckExtensionPeriod": return int.class;
case "maxmessagesperpoll":
case "maxMessagesPerPoll": return java.lang.Integer.class;
case "messageorderingenabled":
@@ -108,6 +112,8 @@ public class GooglePubsubEndpointConfigurer extends
PropertyConfigurerSupport im
case "lazyStartProducer": return target.isLazyStartProducer();
case "loggerid":
case "loggerId": return target.getLoggerId();
+ case "maxackextensionperiod":
+ case "maxAckExtensionPeriod": return target.getMaxAckExtensionPeriod();
case "maxmessagesperpoll":
case "maxMessagesPerPoll": return target.getMaxMessagesPerPoll();
case "messageorderingenabled":
diff --git
a/components/camel-google/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointUriFactory.java
b/components/camel-google/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointUriFactory.java
index 6105e91c6b9..e3efb4ff570 100644
---
a/components/camel-google/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointUriFactory.java
+++
b/components/camel-google/camel-google-pubsub/src/generated/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpointUriFactory.java
@@ -21,7 +21,7 @@ public class GooglePubsubEndpointUriFactory extends
org.apache.camel.support.com
private static final Set<String> SECRET_PROPERTY_NAMES;
private static final Set<String> MULTI_VALUE_PREFIXES;
static {
- Set<String> props = new HashSet<>(16);
+ Set<String> props = new HashSet<>(17);
props.add("ackMode");
props.add("authenticate");
props.add("bridgeErrorHandler");
@@ -31,6 +31,7 @@ public class GooglePubsubEndpointUriFactory extends
org.apache.camel.support.com
props.add("exchangePattern");
props.add("lazyStartProducer");
props.add("loggerId");
+ props.add("maxAckExtensionPeriod");
props.add("maxMessagesPerPoll");
props.add("messageOrderingEnabled");
props.add("projectId");
diff --git
a/components/camel-google/camel-google-pubsub/src/generated/resources/org/apache/camel/component/google/pubsub/google-pubsub.json
b/components/camel-google/camel-google-pubsub/src/generated/resources/org/apache/camel/component/google/pubsub/google-pubsub.json
index 55c6f3032a0..26c5f6dc7f3 100644
---
a/components/camel-google/camel-google-pubsub/src/generated/resources/org/apache/camel/component/google/pubsub/google-pubsub.json
+++
b/components/camel-google/camel-google-pubsub/src/generated/resources/org/apache/camel/component/google/pubsub/google-pubsub.json
@@ -48,6 +48,7 @@
"serviceAccountKey": { "kind": "parameter", "displayName": "Service
Account Key", "group": "common", "label": "common", "required": false, "type":
"string", "javaType": "java.lang.String", "deprecated": false, "autowired":
false, "secret": false, "description": "The Service account key that can be
used as credentials for the PubSub publisher\/subscriber. It can be loaded by
default from classpath, but you can prefix with classpath:, file:, or http: to
load the resource from different [...]
"ackMode": { "kind": "parameter", "displayName": "Ack Mode", "group":
"consumer", "label": "consumer", "required": false, "type": "object",
"javaType":
"org.apache.camel.component.google.pubsub.GooglePubsubConstants.AckMode",
"enum": [ "AUTO", "NONE" ], "deprecated": false, "autowired": false, "secret":
false, "defaultValue": "AUTO", "description": "AUTO = exchange gets
ack'ed\/nack'ed on completion. NONE = downstream process has to ack\/nack
explicitly" },
"concurrentConsumers": { "kind": "parameter", "displayName": "Concurrent
Consumers", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "java.lang.Integer", "deprecated": false,
"autowired": false, "secret": false, "defaultValue": "1", "description": "The
number of parallel streams consuming from the subscription" },
+ "maxAckExtensionPeriod": { "kind": "parameter", "displayName": "Max Ack
Extension Period", "group": "consumer", "label": "consumer", "required": false,
"type": "integer", "javaType": "int", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": 3600, "description": "Set the maximum period a
message ack deadline will be extended. Value in seconds" },
"maxMessagesPerPoll": { "kind": "parameter", "displayName": "Max Messages
Per Poll", "group": "consumer", "label": "consumer", "required": false, "type":
"integer", "javaType": "java.lang.Integer", "deprecated": false, "autowired":
false, "secret": false, "defaultValue": "1", "description": "The max number of
messages to receive from the server in a single API call" },
"synchronousPull": { "kind": "parameter", "displayName": "Synchronous
Pull", "group": "consumer", "label": "consumer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Synchronously pull
batches of messages" },
"bridgeErrorHandler": { "kind": "parameter", "displayName": "Bridge Error
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"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 [...]
