You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@inlong.apache.org by GitBox <gi...@apache.org> on 2022/01/23 06:43:45 UTC

[GitHub] [incubator-inlong] gosonzhang commented on a change in pull request #2280: [INLONG-2279][Improve] Supplement TubeMQ's Javadoc information

gosonzhang commented on a change in pull request #2280:
URL: https://github.com/apache/incubator-inlong/pull/2280#discussion_r790234469



##########
File path: inlong-tubemq/tubemq-example/src/main/java/org/apache/inlong/tubemq/example/MAMessageProducerExample.java
##########
@@ -54,14 +54,19 @@
     private static final AtomicLong totalSentCnt = new AtomicLong(0);
     private static ExecutorService sendExecutorService;
 
-    // The 1st parameter masterServers format is master1_ip:port[,master2_ip:port],
-    //     the master address(es) to connect to;
-    // The 2nd parameter pubTopicAndFilterItems format is topic_1[[:filterCond_1.1[;filterCond_1.2]][,topic_2]]
-    //     the topic(s) (and filter condition set) to publish to.
-    // The 3rd parameter msgCount is the message amount that needs to be sent
-    // The 4th parameter pkgSize is the message's body size that needs to be sent
-    // The 5th parameter clientCount is the amount of producer
-    // The 6th parameter sessionFactoryCnt is the amount of session factory
+    /***

Review comment:
       ok, done




-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscribe@inlong.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org