[TUBEMQ-446]Small bugs fix that do not affect the main logics (apache…

…#346) Co-authored-by: gosonzhang <gosonzhang@tencent.com>
EMsnap · Jan 7, 2021 · 8eaba3a · 8eaba3a
1 parent 1a5980b
commit 8eaba3a
Show file tree

Hide file tree

Showing 3 changed files with 4 additions and 2 deletions.
diff --git a/tubemq-core/src/main/java/org/apache/tubemq/corebase/utils/AddressUtils.java b/tubemq-core/src/main/java/org/apache/tubemq/corebase/utils/AddressUtils.java
@@ -144,6 +144,9 @@ public static Enumeration<NetworkInterface> listNetworkInterface() {
     }
 
     public static String getIPV4LocalAddress() {
+        if (localIPAddress != null) {
+            return localIPAddress;
+        }
         String tmpAdress = null;
         try {
             Enumeration<NetworkInterface> enumeration = NetworkInterface.getNetworkInterfaces();

diff --git a/tubemq-example/src/main/java/org/apache/tubemq/example/MessageConsumerExample.java b/tubemq-example/src/main/java/org/apache/tubemq/example/MessageConsumerExample.java
@@ -96,7 +96,7 @@ public static void main(String[] args) {
             topicTidsMap.put(topicTidStr[0], tids);
         }
         final int startFetchCount = fetchCount;
-        final ExecutorService executorService = Executors.newFixedThreadPool(fetchCount);
+        final ExecutorService executorService = Executors.newCachedThreadPool();
         for (int i = 0; i < consumerCount; i++) {
             executorService.submit(new Runnable() {
                 @Override

diff --git a/tubemq-server/src/main/java/org/apache/tubemq/server/tools/cli/CliConsumer.java b/tubemq-server/src/main/java/org/apache/tubemq/server/tools/cli/CliConsumer.java
@@ -103,7 +103,6 @@ protected void initCommandOptions() {
         addCommandOption(CliArgDef.FETCHTHREADS);
         addCommandOption(CliArgDef.CLIENTCOUNT);
         addCommandOption(CliArgDef.OUTPUTINTERVAL);
-        addCommandOption(CliArgDef.WITHOUTDELAY);
     }
 
     public boolean parseParams(String[] args) throws Exception {