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 97ad8c41bed36dc02252954b915082432001ca40 Author: Andrea Cosentino <anco...@gmail.com> 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 f063b77..e02b532 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,18 +68,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;