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 187c51aa7548d89b81d1cdb05cefedb2a22e9f27
Author: Andrea Cosentino <anco...@gmail.com>
AuthorDate: Fri Sep 10 11:13:30 2021 +0200
Regen
---
.../component/google/pubsub/google-pubsub.json | 8 +-
.../src/main/docs/google-pubsub-component.adoc | 8 +-
.../google/pubsub/GooglePubsubEndpoint.java | 6 +-
.../dsl/GooglePubsubEndpointBuilderFactory.java | 472 +++++----------------
.../ROOT/pages/google-pubsub-component.adoc | 8 +-
5 files changed, 117 insertions(+), 385 deletions(-)
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 9578fe4..8462ae1 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
@@ -35,14 +35,14 @@
"properties": {
"projectId": { "kind": "path", "displayName": "Project Id", "group":
"common", "label": "common", "required": true, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "deprecationNote": "", "autowired":
false, "secret": false, "description": "The Google Cloud PubSub Project Id" },
"destinationName": { "kind": "path", "displayName": "Destination Name",
"group": "common", "label": "common", "required": true, "type": "string",
"javaType": "java.lang.String", "deprecated": false, "deprecationNote": "",
"autowired": false, "secret": false, "description": "The Destination Name. For
the consumer this will be the subscription name, while for the producer this
will be the topic name." },
- "ackMode": { "kind": "parameter", "displayName": "Ack Mode", "group":
"common", "label": "", "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" },
"authenticate": { "kind": "parameter", "displayName": "Authenticate",
"group": "common", "label": "common", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": true, "description": "Use Credentials when interacting
with PubSub service (no authentication is required when using emulator)." },
- "concurrentConsumers": { "kind": "parameter", "displayName": "Concurrent
Consumers", "group": "common", "label": "", "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" },
"loggerId": { "kind": "parameter", "displayName": "Logger Id", "group":
"common", "label": "", "required": false, "type": "string", "javaType":
"java.lang.String", "deprecated": false, "autowired": false, "secret": false,
"description": "Logger ID to use when a match to the parent route required" },
- "maxMessagesPerPoll": { "kind": "parameter", "displayName": "Max Messages
Per Poll", "group": "common", "label": "", "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" },
"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 [...]
- "synchronousPull": { "kind": "parameter", "displayName": "Synchronous
Pull", "group": "common", "label": "", "required": false, "type": "boolean",
"javaType": "boolean", "deprecated": false, "autowired": false, "secret":
false, "defaultValue": false, "description": "Synchronously pull batches of
messages" },
+ "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" },
"bridgeErrorHandler": { "kind": "parameter", "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 m [...]
+ "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" },
+ "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" },
"exceptionHandler": { "kind": "parameter", "displayName": "Exception
Handler", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.spi.ExceptionHandler", "optionalPrefix": "consumer.",
"deprecated": false, "autowired": false, "secret": false, "description": "To
let the consumer use a custom ExceptionHandler. Notice if the option
bridgeErrorHandler is enabled then this option is not in use. By default the
con [...]
"exchangePattern": { "kind": "parameter", "displayName": "Exchange
Pattern", "group": "consumer (advanced)", "label": "consumer,advanced",
"required": false, "type": "object", "javaType":
"org.apache.camel.ExchangePattern", "enum": [ "InOnly", "InOut",
"InOptionalOut" ], "deprecated": false, "autowired": false, "secret": false,
"description": "Sets the exchange pattern when the consumer creates an
exchange." },
"lazyStartProducer": { "kind": "parameter", "displayName": "Lazy Start
Producer", "group": "producer", "label": "producer", "required": false, "type":
"boolean", "javaType": "boolean", "deprecated": false, "autowired": false,
"secret": false, "defaultValue": false, "description": "Whether the producer
should be started lazy (on the first message). By starting lazy you can use
this to allow CamelContext and routes to startup in situations where a producer
may otherwise fail during sta [...]
diff --git
a/components/camel-google/camel-google-pubsub/src/main/docs/google-pubsub-component.adoc
b/components/camel-google/camel-google-pubsub/src/main/docs/google-pubsub-component.adoc
index 3dd9fec..ab9c739 100644
---
a/components/camel-google/camel-google-pubsub/src/main/docs/google-pubsub-component.adoc
+++
b/components/camel-google/camel-google-pubsub/src/main/docs/google-pubsub-component.adoc
@@ -128,14 +128,14 @@ with the following path and query parameters:
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
-| *ackMode* (common) | AUTO = exchange gets ack'ed/nack'ed on completion. NONE
= downstream process has to ack/nack explicitly. There are 2 enums and the
value can be one of: AUTO, NONE | AUTO | AckMode
| *authenticate* (common) | Use Credentials when interacting with PubSub
service (no authentication is required when using emulator). | true | boolean
-| *concurrentConsumers* (common) | The number of parallel streams consuming
from the subscription | 1 | Integer
| *loggerId* (common) | Logger ID to use when a match to the parent route
required | | String
-| *maxMessagesPerPoll* (common) | The max number of messages to receive from
the server in a single API call | 1 | Integer
| *serviceAccountKey* (common) | 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 systems. | | String
-| *synchronousPull* (common) | Synchronously pull batches of messages | false
| boolean
+| *ackMode* (consumer) | AUTO = exchange gets ack'ed/nack'ed on completion.
NONE = downstream process has to ack/nack explicitly. There are 2 enums and the
value can be one of: AUTO, NONE | AUTO | AckMode
| *bridgeErrorHandler* (consumer) | 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 message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
+| *concurrentConsumers* (consumer) | The number of parallel streams consuming
from the subscription | 1 | Integer
+| *maxMessagesPerPoll* (consumer) | The max number of messages to receive from
the server in a single API call | 1 | Integer
+| *synchronousPull* (consumer) | Synchronously pull batches of messages |
false | boolean
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
| *lazyStartProducer* (producer) | Whether the producer should be started lazy
(on the first message). By starting lazy you can use this to allow CamelContext
and routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
diff --git
a/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
b/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
index e02b532..b8a4a8d 100644
---
a/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
+++
b/components/camel-google/camel-google-pubsub/src/main/java/org/apache/camel/component/google/pubsub/GooglePubsubEndpoint.java
@@ -68,7 +68,8 @@ public class GooglePubsubEndpoint extends DefaultEndpoint {
@UriParam(name = "loggerId", description = "Logger ID to use when a match
to the parent route required")
private String loggerId;
- @UriParam(label = "consumer", name = "concurrentConsumers", description =
"The number of parallel streams consuming from the subscription",
+ @UriParam(label = "consumer", name = "concurrentConsumers",
+ description = "The number of parallel streams consuming from the
subscription",
defaultValue = "1")
private Integer concurrentConsumers = 1;
@@ -76,7 +77,8 @@ public class GooglePubsubEndpoint extends DefaultEndpoint {
description = "The max number of messages to receive from the
server in a single API call", defaultValue = "1")
private Integer maxMessagesPerPoll = 1;
- @UriParam(label = "consumer", name = "synchronousPull", description =
"Synchronously pull batches of messages", defaultValue = "false")
+ @UriParam(label = "consumer", name = "synchronousPull", description =
"Synchronously pull batches of messages",
+ defaultValue = "false")
private boolean synchronousPull;
@UriParam(label = "consumer", defaultValue = "AUTO", enums = "AUTO,NONE",
diff --git
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
index 598d891..62edb78 100644
---
a/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
+++
b/core/camel-endpointdsl/src/generated/java/org/apache/camel/builder/endpoint/dsl/GooglePubsubEndpointBuilderFactory.java
@@ -42,6 +42,73 @@ public interface GooglePubsubEndpointBuilderFactory {
return (AdvancedGooglePubsubEndpointConsumerBuilder) this;
}
/**
+ * Use Credentials when interacting with PubSub service (no
+ * authentication is required when using emulator).
+ *
+ * The option is a: <code>boolean</code> type.
+ *
+ * Default: true
+ * Group: common
+ *
+ * @param authenticate the value to set
+ * @return the dsl builder
+ */
+ default GooglePubsubEndpointConsumerBuilder authenticate(
+ boolean authenticate) {
+ doSetProperty("authenticate", authenticate);
+ return this;
+ }
+ /**
+ * Use Credentials when interacting with PubSub service (no
+ * authentication is required when using emulator).
+ *
+ * The option will be converted to a <code>boolean</code>
+ * type.
+ *
+ * Default: true
+ * Group: common
+ *
+ * @param authenticate the value to set
+ * @return the dsl builder
+ */
+ default GooglePubsubEndpointConsumerBuilder authenticate(
+ String authenticate) {
+ doSetProperty("authenticate", authenticate);
+ return this;
+ }
+ /**
+ * Logger ID to use when a match to the parent route required.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param loggerId the value to set
+ * @return the dsl builder
+ */
+ default GooglePubsubEndpointConsumerBuilder loggerId(String loggerId) {
+ doSetProperty("loggerId", loggerId);
+ return this;
+ }
+ /**
+ * 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 systems.
+ *
+ * The option is a: <code>java.lang.String</code> type.
+ *
+ * Group: common
+ *
+ * @param serviceAccountKey the value to set
+ * @return the dsl builder
+ */
+ default GooglePubsubEndpointConsumerBuilder serviceAccountKey(
+ String serviceAccountKey) {
+ doSetProperty("serviceAccountKey", serviceAccountKey);
+ return this;
+ }
+ /**
* AUTO = exchange gets ack'ed/nack'ed on completion. NONE = downstream
* process has to ack/nack explicitly.
*
@@ -49,7 +116,7 @@ public interface GooglePubsubEndpointBuilderFactory {
*
<code>org.apache.camel.component.google.pubsub.GooglePubsubConstants$AckMode</code>
type.
*
* Default: AUTO
- * Group: common
+ * Group: consumer
*
* @param ackMode the value to set
* @return the dsl builder
@@ -66,7 +133,7 @@ public interface GooglePubsubEndpointBuilderFactory {
*
<code>org.apache.camel.component.google.pubsub.GooglePubsubConstants$AckMode</code>
type.
*
* Default: AUTO
- * Group: common
+ * Group: consumer
*
* @param ackMode the value to set
* @return the dsl builder
@@ -76,38 +143,48 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
- * Use Credentials when interacting with PubSub service (no
- * authentication is required when using emulator).
+ * 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
+ * message and handled by the routing Error Handler. By default the
+ * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
+ * with exceptions, that will be logged at WARN or ERROR level and
+ * ignored.
*
* The option is a: <code>boolean</code> type.
*
- * Default: true
- * Group: common
+ * Default: false
+ * Group: consumer
*
- * @param authenticate the value to set
+ * @param bridgeErrorHandler the value to set
* @return the dsl builder
*/
- default GooglePubsubEndpointConsumerBuilder authenticate(
- boolean authenticate) {
- doSetProperty("authenticate", authenticate);
+ default GooglePubsubEndpointConsumerBuilder bridgeErrorHandler(
+ boolean bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
return this;
}
/**
- * Use Credentials when interacting with PubSub service (no
- * authentication is required when using emulator).
+ * 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
+ * message and handled by the routing Error Handler. By default the
+ * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
+ * with exceptions, that will be logged at WARN or ERROR level and
+ * ignored.
*
* The option will be converted to a <code>boolean</code>
* type.
*
- * Default: true
- * Group: common
+ * Default: false
+ * Group: consumer
*
- * @param authenticate the value to set
+ * @param bridgeErrorHandler the value to set
* @return the dsl builder
*/
- default GooglePubsubEndpointConsumerBuilder authenticate(
- String authenticate) {
- doSetProperty("authenticate", authenticate);
+ default GooglePubsubEndpointConsumerBuilder bridgeErrorHandler(
+ String bridgeErrorHandler) {
+ doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
return this;
}
/**
@@ -116,7 +193,7 @@ public interface GooglePubsubEndpointBuilderFactory {
* The option is a: <code>java.lang.Integer</code> type.
*
* Default: 1
- * Group: common
+ * Group: consumer
*
* @param concurrentConsumers the value to set
* @return the dsl builder
@@ -133,7 +210,7 @@ public interface GooglePubsubEndpointBuilderFactory {
* <code>java.lang.Integer</code> type.
*
* Default: 1
- * Group: common
+ * Group: consumer
*
* @param concurrentConsumers the value to set
* @return the dsl builder
@@ -144,27 +221,13 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
- * Logger ID to use when a match to the parent route required.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param loggerId the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointConsumerBuilder loggerId(String loggerId) {
- doSetProperty("loggerId", loggerId);
- return this;
- }
- /**
* The max number of messages to receive from the server in a single
API
* call.
*
* The option is a: <code>java.lang.Integer</code> type.
*
* Default: 1
- * Group: common
+ * Group: consumer
*
* @param maxMessagesPerPoll the value to set
* @return the dsl builder
@@ -182,7 +245,7 @@ public interface GooglePubsubEndpointBuilderFactory {
* <code>java.lang.Integer</code> type.
*
* Default: 1
- * Group: common
+ * Group: consumer
*
* @param maxMessagesPerPoll the value to set
* @return the dsl builder
@@ -193,30 +256,12 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
- * 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 systems.
- *
- * The option is a: <code>java.lang.String</code> type.
- *
- * Group: common
- *
- * @param serviceAccountKey the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointConsumerBuilder serviceAccountKey(
- String serviceAccountKey) {
- doSetProperty("serviceAccountKey", serviceAccountKey);
- return this;
- }
- /**
* Synchronously pull batches of messages.
*
* The option is a: <code>boolean</code> type.
*
* Default: false
- * Group: common
+ * Group: consumer
*
* @param synchronousPull the value to set
* @return the dsl builder
@@ -233,7 +278,7 @@ public interface GooglePubsubEndpointBuilderFactory {
* type.
*
* Default: false
- * Group: common
+ * Group: consumer
*
* @param synchronousPull the value to set
* @return the dsl builder
@@ -243,51 +288,6 @@ public interface GooglePubsubEndpointBuilderFactory {
doSetProperty("synchronousPull", synchronousPull);
return this;
}
- /**
- * 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
- * message and handled by the routing Error Handler. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointConsumerBuilder bridgeErrorHandler(
- boolean bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
- /**
- * 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
- * message and handled by the routing Error Handler. By default the
- * consumer will use the org.apache.camel.spi.ExceptionHandler to deal
- * with exceptions, that will be logged at WARN or ERROR level and
- * ignored.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: consumer
- *
- * @param bridgeErrorHandler the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointConsumerBuilder bridgeErrorHandler(
- String bridgeErrorHandler) {
- doSetProperty("bridgeErrorHandler", bridgeErrorHandler);
- return this;
- }
}
/**
@@ -381,40 +381,6 @@ public interface GooglePubsubEndpointBuilderFactory {
return (AdvancedGooglePubsubEndpointProducerBuilder) this;
}
/**
- * AUTO = exchange gets ack'ed/nack'ed on completion. NONE = downstream
- * process has to ack/nack explicitly.
- *
- * The option is a:
- *
<code>org.apache.camel.component.google.pubsub.GooglePubsubConstants$AckMode</code>
type.
- *
- * Default: AUTO
- * Group: common
- *
- * @param ackMode the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointProducerBuilder ackMode(AckMode ackMode) {
- doSetProperty("ackMode", ackMode);
- return this;
- }
- /**
- * AUTO = exchange gets ack'ed/nack'ed on completion. NONE = downstream
- * process has to ack/nack explicitly.
- *
- * The option will be converted to a
- *
<code>org.apache.camel.component.google.pubsub.GooglePubsubConstants$AckMode</code>
type.
- *
- * Default: AUTO
- * Group: common
- *
- * @param ackMode the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointProducerBuilder ackMode(String ackMode) {
- doSetProperty("ackMode", ackMode);
- return this;
- }
- /**
* Use Credentials when interacting with PubSub service (no
* authentication is required when using emulator).
*
@@ -450,39 +416,6 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
- * The number of parallel streams consuming from the subscription.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Default: 1
- * Group: common
- *
- * @param concurrentConsumers the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointProducerBuilder concurrentConsumers(
- Integer concurrentConsumers) {
- doSetProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * The number of parallel streams consuming from the subscription.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Default: 1
- * Group: common
- *
- * @param concurrentConsumers the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointProducerBuilder concurrentConsumers(
- String concurrentConsumers) {
- doSetProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
* Logger ID to use when a match to the parent route required.
*
* The option is a: <code>java.lang.String</code> type.
@@ -497,41 +430,6 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
- * The max number of messages to receive from the server in a single
API
- * call.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Default: 1
- * Group: common
- *
- * @param maxMessagesPerPoll the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointProducerBuilder maxMessagesPerPoll(
- Integer maxMessagesPerPoll) {
- doSetProperty("maxMessagesPerPoll", maxMessagesPerPoll);
- return this;
- }
- /**
- * The max number of messages to receive from the server in a single
API
- * call.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Default: 1
- * Group: common
- *
- * @param maxMessagesPerPoll the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointProducerBuilder maxMessagesPerPoll(
- String maxMessagesPerPoll) {
- doSetProperty("maxMessagesPerPoll", maxMessagesPerPoll);
- return this;
- }
- /**
* 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
@@ -550,39 +448,6 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
- * Synchronously pull batches of messages.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: common
- *
- * @param synchronousPull the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointProducerBuilder synchronousPull(
- boolean synchronousPull) {
- doSetProperty("synchronousPull", synchronousPull);
- return this;
- }
- /**
- * Synchronously pull batches of messages.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: common
- *
- * @param synchronousPull the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointProducerBuilder synchronousPull(
- String synchronousPull) {
- doSetProperty("synchronousPull", synchronousPull);
- return this;
- }
- /**
* Whether the producer should be started lazy (on the first message).
* By starting lazy you can use this to allow CamelContext and routes
to
* startup in situations where a producer may otherwise fail during
@@ -739,40 +604,6 @@ public interface GooglePubsubEndpointBuilderFactory {
return (AdvancedGooglePubsubEndpointBuilder) this;
}
/**
- * AUTO = exchange gets ack'ed/nack'ed on completion. NONE = downstream
- * process has to ack/nack explicitly.
- *
- * The option is a:
- *
<code>org.apache.camel.component.google.pubsub.GooglePubsubConstants$AckMode</code>
type.
- *
- * Default: AUTO
- * Group: common
- *
- * @param ackMode the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointBuilder ackMode(AckMode ackMode) {
- doSetProperty("ackMode", ackMode);
- return this;
- }
- /**
- * AUTO = exchange gets ack'ed/nack'ed on completion. NONE = downstream
- * process has to ack/nack explicitly.
- *
- * The option will be converted to a
- *
<code>org.apache.camel.component.google.pubsub.GooglePubsubConstants$AckMode</code>
type.
- *
- * Default: AUTO
- * Group: common
- *
- * @param ackMode the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointBuilder ackMode(String ackMode) {
- doSetProperty("ackMode", ackMode);
- return this;
- }
- /**
* Use Credentials when interacting with PubSub service (no
* authentication is required when using emulator).
*
@@ -806,39 +637,6 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
- * The number of parallel streams consuming from the subscription.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Default: 1
- * Group: common
- *
- * @param concurrentConsumers the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointBuilder concurrentConsumers(
- Integer concurrentConsumers) {
- doSetProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
- * The number of parallel streams consuming from the subscription.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Default: 1
- * Group: common
- *
- * @param concurrentConsumers the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointBuilder concurrentConsumers(
- String concurrentConsumers) {
- doSetProperty("concurrentConsumers", concurrentConsumers);
- return this;
- }
- /**
* Logger ID to use when a match to the parent route required.
*
* The option is a: <code>java.lang.String</code> type.
@@ -853,41 +651,6 @@ public interface GooglePubsubEndpointBuilderFactory {
return this;
}
/**
- * The max number of messages to receive from the server in a single
API
- * call.
- *
- * The option is a: <code>java.lang.Integer</code> type.
- *
- * Default: 1
- * Group: common
- *
- * @param maxMessagesPerPoll the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointBuilder maxMessagesPerPoll(
- Integer maxMessagesPerPoll) {
- doSetProperty("maxMessagesPerPoll", maxMessagesPerPoll);
- return this;
- }
- /**
- * The max number of messages to receive from the server in a single
API
- * call.
- *
- * The option will be converted to a
- * <code>java.lang.Integer</code> type.
- *
- * Default: 1
- * Group: common
- *
- * @param maxMessagesPerPoll the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointBuilder maxMessagesPerPoll(
- String maxMessagesPerPoll) {
- doSetProperty("maxMessagesPerPoll", maxMessagesPerPoll);
- return this;
- }
- /**
* 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
@@ -905,39 +668,6 @@ public interface GooglePubsubEndpointBuilderFactory {
doSetProperty("serviceAccountKey", serviceAccountKey);
return this;
}
- /**
- * Synchronously pull batches of messages.
- *
- * The option is a: <code>boolean</code> type.
- *
- * Default: false
- * Group: common
- *
- * @param synchronousPull the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointBuilder synchronousPull(
- boolean synchronousPull) {
- doSetProperty("synchronousPull", synchronousPull);
- return this;
- }
- /**
- * Synchronously pull batches of messages.
- *
- * The option will be converted to a <code>boolean</code>
- * type.
- *
- * Default: false
- * Group: common
- *
- * @param synchronousPull the value to set
- * @return the dsl builder
- */
- default GooglePubsubEndpointBuilder synchronousPull(
- String synchronousPull) {
- doSetProperty("synchronousPull", synchronousPull);
- return this;
- }
}
/**
diff --git a/docs/components/modules/ROOT/pages/google-pubsub-component.adoc
b/docs/components/modules/ROOT/pages/google-pubsub-component.adoc
index 9d77e69..669a935 100644
--- a/docs/components/modules/ROOT/pages/google-pubsub-component.adoc
+++ b/docs/components/modules/ROOT/pages/google-pubsub-component.adoc
@@ -130,14 +130,14 @@ with the following path and query parameters:
[width="100%",cols="2,5,^1,2",options="header"]
|===
| Name | Description | Default | Type
-| *ackMode* (common) | AUTO = exchange gets ack'ed/nack'ed on completion. NONE
= downstream process has to ack/nack explicitly. There are 2 enums and the
value can be one of: AUTO, NONE | AUTO | AckMode
| *authenticate* (common) | Use Credentials when interacting with PubSub
service (no authentication is required when using emulator). | true | boolean
-| *concurrentConsumers* (common) | The number of parallel streams consuming
from the subscription | 1 | Integer
| *loggerId* (common) | Logger ID to use when a match to the parent route
required | | String
-| *maxMessagesPerPoll* (common) | The max number of messages to receive from
the server in a single API call | 1 | Integer
| *serviceAccountKey* (common) | 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 systems. | | String
-| *synchronousPull* (common) | Synchronously pull batches of messages | false
| boolean
+| *ackMode* (consumer) | AUTO = exchange gets ack'ed/nack'ed on completion.
NONE = downstream process has to ack/nack explicitly. There are 2 enums and the
value can be one of: AUTO, NONE | AUTO | AckMode
| *bridgeErrorHandler* (consumer) | 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 message and handled by the routing Error Handler. By default the
consumer will use the org.apache.camel.spi.ExceptionHandler to deal with
exceptions, that will be logged at WARN or ERROR level and ignored. | false |
boolean
+| *concurrentConsumers* (consumer) | The number of parallel streams consuming
from the subscription | 1 | Integer
+| *maxMessagesPerPoll* (consumer) | The max number of messages to receive from
the server in a single API call | 1 | Integer
+| *synchronousPull* (consumer) | Synchronously pull batches of messages |
false | boolean
| *exceptionHandler* (consumer) | To let the consumer use a custom
ExceptionHandler. Notice if the option bridgeErrorHandler is enabled then this
option is not in use. By default the consumer will deal with exceptions, that
will be logged at WARN or ERROR level and ignored. | | ExceptionHandler
| *exchangePattern* (consumer) | Sets the exchange pattern when the consumer
creates an exchange. There are 3 enums and the value can be one of: InOnly,
InOut, InOptionalOut | | ExchangePattern
| *lazyStartProducer* (producer) | Whether the producer should be started lazy
(on the first message). By starting lazy you can use this to allow CamelContext
and routes to startup in situations where a producer may otherwise fail during
starting and cause the route to fail being started. By deferring this startup
to be lazy then the startup failure can be handled during routing messages via
Camel's routing error handlers. Beware that when the first message is processed
then creating and [...]
