This is an automated email from the ASF dual-hosted git repository.
acosentino pushed a commit to branch camel-3.11.x
in repository https://gitbox.apache.org/repos/asf/camel.git
The following commit(s) were added to refs/heads/camel-3.11.x by this push:
new 73d65bc Camel-Google-Pubsub: Correctly labeling consumer endpoint
options
73d65bc is described below
commit 73d65bc977b4a1b714c72a3e11177cde3b8fa2eb
Author: Andrea Cosentino <[email protected]>
AuthorDate: Fri Sep 10 11:11:48 2021 +0200
Camel-Google-Pubsub: Correctly labeling consumer endpoint options
---
.../camel/component/google/pubsub/GooglePubsubEndpoint.java | 8 ++++----
1 file changed, 4 insertions(+), 4 deletions(-)
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 183fb52..4160669 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
@@ -64,18 +64,18 @@ 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(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;
- @UriParam(name = "maxMessagesPerPoll",
+ @UriParam(label = "consumer", name = "maxMessagesPerPoll",
description = "The max number of messages to receive from the
server in a single API call", defaultValue = "1")
private Integer maxMessagesPerPoll = 1;
- @UriParam(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(defaultValue = "AUTO", enums = "AUTO,NONE",
+ @UriParam(label = "consumer", defaultValue = "AUTO", enums = "AUTO,NONE",
description = "AUTO = exchange gets ack'ed/nack'ed on
completion. NONE = downstream process has to ack/nack explicitly")
private GooglePubsubConstants.AckMode ackMode =
GooglePubsubConstants.AckMode.AUTO;