[pulsar] branch master updated: Remove redundant parameter totalMessages (#4583)

[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 7a24136  Remove redundant parameter totalMessages (#4583)
7a24136 is described below

commit 7a24136cedf28559acf0e2b08eed594c4f3264eb
Author: Like <ke.l...@outlook.com>
AuthorDate: Sat Jun 29 23:19:03 2019 +0800

    Remove redundant parameter totalMessages (#4583)
    
    Remove redundant parameter ```totalMessages``` for publish method.
---
 .../main/java/org/apache/pulsar/client/cli/CmdProduce.java    | 11 ++++-------
 1 file changed, 4 insertions(+), 7 deletions(-)

diff --git 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java
 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java
index 990ac25..006be6c 100644
--- 
a/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java
+++ 
b/pulsar-client-tools/src/main/java/org/apache/pulsar/client/cli/CmdProduce.java
@@ -24,8 +24,6 @@ import com.beust.jcommander.Parameters;
 import com.fasterxml.jackson.core.JsonProcessingException;
 import com.google.common.collect.Lists;
 import com.google.common.util.concurrent.RateLimiter;
-import com.google.gson.Gson;
-import com.google.gson.JsonObject;
 import com.google.gson.JsonParseException;
 
 import java.net.URI;
@@ -37,7 +35,6 @@ import java.util.List;
 import java.util.Map;
 import java.util.concurrent.CompletableFuture;
 import java.util.concurrent.CountDownLatch;
-import java.util.concurrent.Future;
 import java.util.concurrent.TimeUnit;
 
 import org.apache.commons.lang3.StringUtils;
@@ -164,13 +161,13 @@ public class CmdProduce {
         String topic = this.mainOptions.get(0);
 
         if (this.serviceURL.startsWith("ws")) {
-            return publishToWebSocket(totalMessages, topic);
+            return publishToWebSocket(topic);
         } else {
-            return publish(totalMessages, topic);
+            return publish(topic);
         }
     }
 
-    private int publish(int totalMessages, String topic) {
+    private int publish(String topic) {
         int numMessagesSent = 0;
         int returnCode = 0;
 
@@ -203,7 +200,7 @@ public class CmdProduce {
     }
 
     @SuppressWarnings("deprecation")
-    private int publishToWebSocket(int totalMessages, String topic) {
+    private int publishToWebSocket(String topic) {
         int numMessagesSent = 0;
         int returnCode = 0;