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;
 

Reply via email to