[pulsar] branch master updated: Fix the params broken by PR #4400 (#7795)

[sijie]

This is an automated email from the ASF dual-hosted git repository.

sijie pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/pulsar.git


The following commit(s) were added to refs/heads/master by this push:
     new a4a12d1  Fix the params broken by PR #4400 (#7795)
a4a12d1 is described below

commit a4a12d1da38c1cc0a75855f5bf53c1a04ee49ee1
Author: Emmanuel Feller <emmanuel.fel...@gmail.com>
AuthorDate: Wed Aug 12 00:49:29 2020 +0200

    Fix the params broken by PR #4400 (#7795)
    
    ### Motivation
    The PR #4400 introduced new params on the pulsar-client consume command but 
it broked some old ones.
    
    ### Modifications
    
    This PR fixes this problem to restore the good param behavior.
---
 .../main/java/org/apache/pulsar/client/cli/CmdConsume.java   | 12 ++++++------
 1 file changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
index 1812a96..5bca4d4 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdConsume.java
@@ -205,16 +205,16 @@ public class CmdConsume {
                 builder.topic(topic);
             }
 
-            ConsumerBuilder<byte[]> consumerBuilder = 
client.newConsumer().topic(topic);
             if (this.maxPendingChuckedMessage > 0) {
-                
consumerBuilder.maxPendingChuckedMessage(this.maxPendingChuckedMessage);
+                
builder.maxPendingChuckedMessage(this.maxPendingChuckedMessage);
             }
             if (this.receiverQueueSize > 0) {
-                
consumerBuilder.maxPendingChuckedMessage(this.receiverQueueSize);
+                builder.receiverQueueSize(this.receiverQueueSize);
             }
-            Consumer<byte[]> consumer = 
consumerBuilder.subscriptionName(this.subscriptionName)
-                    
.autoAckOldestChunkedMessageOnQueueFull(this.autoAckOldestChunkedMessageOnQueueFull)
-                    .subscriptionType(subscriptionType).subscribe();
+
+            
builder.autoAckOldestChunkedMessageOnQueueFull(this.autoAckOldestChunkedMessageOnQueueFull);
+
+            Consumer<byte[]> consumer = builder.subscribe();
 
             RateLimiter limiter = (this.consumeRate > 0) ? 
RateLimiter.create(this.consumeRate) : null;
             while (this.numMessagesToConsume == 0 || numMessagesConsumed < 
this.numMessagesToConsume) {