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

aloyszhang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/incubator-inlong.git


The following commit(s) were added to refs/heads/master by this push:
     new bc58c9e  [INLONG-2294]Rename the variable BROKER_VERSION to 
SERVER_VERSION (#2295)
bc58c9e is described below

commit bc58c9ee0d58f52cf4ebe562d09795160f9900c1
Author: gosonzhang <[email protected]>
AuthorDate: Mon Jan 24 14:29:29 2022 +0800

    [INLONG-2294]Rename the variable BROKER_VERSION to SERVER_VERSION (#2295)
---
 .../main/java/org/apache/inlong/tubemq/server/broker/TubeBroker.java  | 4 ++--
 .../tubemq/server/master/web/action/screen/config/BrokerList.java     | 2 +-
 .../org/apache/inlong/tubemq/server/tools/cli/CliAbstractBase.java    | 2 +-
 inlong-tubemq/tubemq-server/src/saveServerVersion.cmd                 | 2 +-
 inlong-tubemq/tubemq-server/src/saveServerVersion.sh                  | 2 +-
 5 files changed, 6 insertions(+), 6 deletions(-)

diff --git 
a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/TubeBroker.java
 
b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/TubeBroker.java
index 1f57fac..ad8b319 100644
--- 
a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/TubeBroker.java
+++ 
b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/broker/TubeBroker.java
@@ -256,7 +256,7 @@ public class TubeBroker implements Stoppable {
         isOnline = true;
         logger.info(new StringBuilder(512)
                 .append("Start tube server successfully, broker version=")
-                .append(TubeServerVersion.BROKER_VERSION).toString());
+                .append(TubeServerVersion.SERVER_VERSION).toString());
     }
 
     public synchronized void reloadConfig() {
@@ -311,7 +311,7 @@ public class TubeBroker implements Stoppable {
         return new 
StringBuilder(512).append(tubeConfig.getBrokerId()).append(":")
                 .append(tubeConfig.getHostName()).append(":")
                 .append(tubeConfig.getPort()).append(":")
-                .append(TubeServerVersion.BROKER_VERSION).toString();
+                .append(TubeServerVersion.SERVER_VERSION).toString();
     }
 
     private void procConfigFromHeartBeat(StringBuilder sBuilder,
diff --git 
a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/action/screen/config/BrokerList.java
 
b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/action/screen/config/BrokerList.java
index 624618e..87dcafd 100644
--- 
a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/action/screen/config/BrokerList.java
+++ 
b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/master/web/action/screen/config/BrokerList.java
@@ -98,7 +98,7 @@ public class BrokerList implements Action {
                 brokerVO.setPartitionCount(totalPartitionNum);
                 brokerVO.setReadable(true);
                 brokerVO.setWritable(true);
-                brokerVO.setVersion(TubeServerVersion.BROKER_VERSION);
+                brokerVO.setVersion(TubeServerVersion.SERVER_VERSION);
                 brokerVO.setStatus(1);
                 brokerVO.setLastOpTime(new Date());
                 brokerVOList.add(brokerVO);
diff --git 
a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliAbstractBase.java
 
b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliAbstractBase.java
index aab466a..0160ec6 100644
--- 
a/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliAbstractBase.java
+++ 
b/inlong-tubemq/tubemq-server/src/main/java/org/apache/inlong/tubemq/server/tools/cli/CliAbstractBase.java
@@ -53,7 +53,7 @@ public abstract class CliAbstractBase {
      *
      */
     public void version() {
-        System.out.println("TubeMQ " + TubeServerVersion.BROKER_VERSION);
+        System.out.println("TubeMQ " + TubeServerVersion.SERVER_VERSION);
         System.exit(0);
     }
 
diff --git a/inlong-tubemq/tubemq-server/src/saveServerVersion.cmd 
b/inlong-tubemq/tubemq-server/src/saveServerVersion.cmd
index 6eb47f8..b015a4c 100644
--- a/inlong-tubemq/tubemq-server/src/saveServerVersion.cmd
+++ b/inlong-tubemq/tubemq-server/src/saveServerVersion.cmd
@@ -30,6 +30,6 @@ echo  */>> %tubeServerVersion%
 echo package org.apache.inlong.tubemq.server.common;>> %tubeServerVersion%
 echo,>> %tubeServerVersion%
 echo public class TubeServerVersion {>> %tubeServerVersion%
-echo     public static final String BROKER_VERSION = "%version%";>> 
%tubeServerVersion%
+echo     public static final String SERVER_VERSION = "%version%";>> 
%tubeServerVersion%
 echo } >> %tubeServerVersion%
 
diff --git a/inlong-tubemq/tubemq-server/src/saveServerVersion.sh 
b/inlong-tubemq/tubemq-server/src/saveServerVersion.sh
index 58cb86a..7250e69 100755
--- a/inlong-tubemq/tubemq-server/src/saveServerVersion.sh
+++ b/inlong-tubemq/tubemq-server/src/saveServerVersion.sh
@@ -30,7 +30,7 @@ cat 
>"$outputDirectory/org/apache/inlong/tubemq/server/common/TubeServerVersion.
 package org.apache.inlong.tubemq.server.common;
 
 public class TubeServerVersion {
-    public static final String BROKER_VERSION = "$version";
+    public static final String SERVER_VERSION = "$version";
 }
 EOF
 

Reply via email to