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 <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 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;
 

Reply via email to