This is an automated email from the ASF dual-hosted git repository.
yuanbo pushed a change to branch TUBEMQ-469
in repository https://gitbox.apache.org/repos/asf/incubator-tubemq.git.
from 9de68b6 [TUBEMQ-510] Found a bug in MessageProducerExample class
new 1a69395 rm -Werror
new f733960 add change
new 0476e75 [TUBEMQ-511]Replace the conditional operator (?:) with mid()
new f6ce2be [TUBEMQ-512] Add package length control based on Topic
new b130dab [TUBEMQ-518] fix parameter pass error
new f25db30 [TUBEMQ-515]Add cluster Topic view web api
new 71dfa84 [TUBEMQ-517] Add 0.8.0 version release modification to
CHANGES.md (#399)
new bf217f6 [TUBEMQ-526] Adjust the packaging script and version check
list, remove the "-WIP" tag
new 6fa82bf [TUBEMQ-529] Update CHANGE.md
new c7ab12a [TUBEMQ-544]Adjust the LICENSE statement in the client.conf
files of Python and C/C++ SDK
new ffb5205 [TUBEMQ-546]Restore the original license header of the
referenced external source files
new c469352 [TUBEMQ-551] Adjust NOTICE file content
new 1b0f455 [TUBEMQ-547]Recode the implementation of the *Startup.java
classes in the Tool package
new 444d55a [TUBEMQ-550] Adjust LICENSE file content
new ada8bed [TUBEMQ-550] Adjust LICENSE file content
new 35c0b45 [TUBEMQ-548] Handle the LICENSE authorization of font files
in the resources
new cd02720 [TUBEMQ-549] Handling the problem of compilation failure
new 8a56cf2 [TUBEMQ-553]Update the CHANGES.md according to the 0.8.0-RC1
changes (#418)
new 8a73c16 fix short conversation bug
new 61b204a [TUBEMQ-556]Index value is bigger than the actual number of
records (#422)
new d3ca3f0 [TUBEMQ-558] Adjust the LICENSE of the file header (#424)
new cd21d8f [TUBEMQ-555] short session data can only be written to a
specific partition (addendum) (#423)
new 97eeead [TUBEMQ-560] Remove unprepared modules (#426)
new a080e00 [TUBEMQ-559] Update the LICENSE file according to the
0.8.0-RC2 review (#425)
new fdb0bd6 [TUBEMQ-561] Update the CHANGES.md according to the 0.8.0-RC2
changes (#428)
new 5967037 [TUBEMQ-559] Update the LICENSE file according to the
0.8.0-RC2 review (#427)
new 4c09c1f [TUBEMQ-562]Update project contents according to the
0.8.0-RC3 review (#429)
new 7fb91aa [TUBEMQ-563]Update the CHANGES.md according to the 0.8.0-RC3
changes (#430)
new 2045fee [TUBEMQ-565]Replace simple scripts and code implementation
(#432)
The 29 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails. The revisions
listed as "add" were already present in the repository and have only
been added to this reference.
Summary of changes:
CHANGES.md | 88 ++
DISCLAIMER | 6 -
DISCLAIMER-WIP | 18 +
LICENSE | 541 ++++++------
NOTICE | 143 +++-
bin/broker.sh | 151 ----
bin/master.sh | 154 ----
bin/{tubemq => tubemq.sh} | 0
pom.xml | 19 +-
resources/assets/public/css/fonts/icon.eot | Bin 2340 -> 0 bytes
resources/assets/public/css/fonts/icon.svg | 16 +
resources/assets/public/css/fonts/icon.ttf | Bin 2188 -> 0 bytes
resources/assets/public/css/fonts/icon.woff | Bin 2264 -> 0 bytes
resources/assets/public/css/style.css | 3 +-
resources/assets/scripts/topicList.js | 8 +-
.../tubemq-client-cpp/CMakeLists.txt | 2 +-
.../tubemq-client-cpp/conf/client.conf | 22 +-
tubemq-client-twins/tubemq-client-cpp/src/any.h | 21 +-
tubemq-client-twins/tubemq-client-cpp/src/buffer.h | 22 +-
.../src/python/tubemq/client.conf | 22 +-
.../client/producer/RoundRobinPartitionRouter.java | 3 +-
tubemq-connectors/tubemq-connector-flume/pom.xml | 2 +-
tubemq-core/pom.xml | 4 +
.../tubemq/corebase/utils/ConcurrentHashSet.java | 59 +-
.../apache/tubemq/corebase/utils/MapBackedSet.java | 76 --
.../apache/tubemq/corebase/utils/TStringUtils.java | 947 ++-------------------
...ssUtilsTest.java => ConcurrentHashSetTest.java} | 27 +-
tubemq-docker/tubemq-all/Dockerfile | 20 +-
tubemq-docker/tubemq-all/tubemq.sh | 8 +-
tubemq-example/src/main/assembly/assembly.xml | 2 +-
tubemq-manager/READMe.md | 51 --
tubemq-manager/bin/start-manager.sh | 60 --
tubemq-manager/bin/stop-manager.sh | 31 -
tubemq-manager/conf/logback.xml | 64 --
tubemq-manager/pom.xml | 130 ---
tubemq-manager/src/main/assembly/assembly.xml | 61 --
.../org/apache/tubemq/manager/TubeMQManager.java | 59 --
.../controller/ManagerControllerAdvice.java | 41 -
.../tubemq/manager/controller/TubeResult.java | 27 -
.../controller/cluster/ClusterController.java | 128 ---
.../manager/controller/topic/TopicController.java | 126 ---
.../org/apache/tubemq/manager/entry/NodeEntry.java | 51 --
.../apache/tubemq/manager/entry/TopicEntry.java | 137 ---
.../apache/tubemq/manager/entry/TopicStatus.java | 33 -
.../manager/exceptions/TubeMQManagerException.java | 28 -
.../tubemq/manager/repository/NodeRepository.java | 28 -
.../tubemq/manager/repository/TopicRepository.java | 43 -
.../apache/tubemq/manager/service/NodeService.java | 272 ------
.../tubemq/manager/service/TopicBackendWorker.java | 137 ---
.../apache/tubemq/manager/service/TopicFuture.java | 58 --
.../tubemq/manager/service/TubeHttpConst.java | 30 -
.../service/tube/TubeHttpBrokerInfoList.java | 135 ---
.../manager/service/tube/TubeHttpResponse.java | 30 -
.../service/tube/TubeHttpTopicInfoList.java | 97 ---
.../src/main/resources/application.properties | 17 -
.../manager/controller/TestBusinessController.java | 99 ---
.../manager/controller/TestClusterController.java | 150 ----
.../manager/repository/TestBusinessRepository.java | 67 --
.../service/tube/TestTubeHttpBrokerResponse.java | 48 --
.../service/tube/TestTubeHttpTopicInfoList.java | 52 --
.../tubemq/server/broker/BrokerServiceServer.java | 12 +-
.../broker/metadata/ClusterConfigHolder.java | 25 +-
.../server/broker/metadata/TopicMetadata.java | 43 +-
.../server/broker/msgstore/MessageStore.java | 27 +-
.../server/broker/offset/DefaultOffsetManager.java | 10 +-
.../server/broker/web/BrokerAdminServlet.java | 29 +-
.../tubemq/server/common/TServerConstants.java | 1 +
.../tubemq/server/common/fielddef/CliArgDef.java | 6 +-
.../server/common/paramcheck/PBParameterUtils.java | 2 +-
.../server/common/utils/WebParameterUtils.java | 21 +-
.../server/common/webbase/WebMethodMapper.java | 2 +-
.../apache/tubemq/server/master/MasterConfig.java | 3 +-
.../bdbstore/bdbentitys/BdbTopicConfEntity.java | 18 +
.../nodemanage/nodebroker/BrokerConfManager.java | 6 +
.../nodebroker/BrokerSyncStatusInfo.java | 15 +
.../web/handler/WebAdminGroupCtrlHandler.java | 2 -
.../web/handler/WebBrokerTopicConfHandler.java | 76 +-
.../master/web/handler/WebMasterInfoHandler.java | 115 ++-
.../master/web/handler/WebOtherInfoHandler.java | 3 +-
.../apache/tubemq/server/tools/BrokerStartup.java | 24 +-
.../org/apache/tubemq/server/tools/CliUtils.java | 72 ++
.../apache/tubemq/server/tools/MasterStartup.java | 21 +-
.../org/apache/tubemq/server/tools/ToolUtils.java | 78 --
.../tubemq/server/tools/cli/CliConsumer.java | 2 +-
.../tubemq/server/tools/cli/CliProducer.java | 2 +-
tubemq-web/.env | 2 -
tubemq-web/.eslintignore | 5 -
tubemq-web/.eslintrc | 28 -
tubemq-web/.gitignore | 26 -
tubemq-web/.prettierrc | 4 -
tubemq-web/.stylelintrc | 3 -
tubemq-web/README.md | 33 -
tubemq-web/config-overrides.js | 52 --
tubemq-web/mock/_constant.js | 3 -
tubemq-web/mock/app.js | 6 -
tubemq-web/package.json | 110 ---
tubemq-web/public/favicon.ico | Bin 1226 -> 0 bytes
tubemq-web/public/index.html | 43 -
tubemq-web/public/logo192.png | Bin 33077 -> 0 bytes
tubemq-web/public/logo512.png | Bin 9664 -> 0 bytes
tubemq-web/public/manifest.json | 24 -
tubemq-web/public/robots.txt | 3 -
tubemq-web/src/components/Breadcrumb/index.less | 8 -
tubemq-web/src/components/Breadcrumb/index.tsx | 47 -
tubemq-web/src/components/Layout/index.less | 31 -
tubemq-web/src/components/Layout/index.tsx | 76 --
tubemq-web/src/components/Modalx/index.less | 17 -
tubemq-web/src/components/Modalx/index.tsx | 49 --
tubemq-web/src/components/Tablex/index.less | 16 -
tubemq-web/src/components/Tablex/index.tsx | 114 ---
.../src/components/Tablex/tableFilterHelper.ts | 32 -
tubemq-web/src/components/TitleWrap/index.less | 11 -
tubemq-web/src/components/TitleWrap/index.tsx | 22 -
tubemq-web/src/components/index.tsx | 3 -
tubemq-web/src/configs/index.ts | 3 -
tubemq-web/src/configs/menus/index.tsx | 50 --
tubemq-web/src/constants/broker.ts | 22 -
tubemq-web/src/constants/person.ts | 4 -
tubemq-web/src/constants/topic.ts | 10 -
tubemq-web/src/context/globalContext.ts | 12 -
tubemq-web/src/defaultSettings.js | 6 -
tubemq-web/src/hooks/index.ts | 52 --
tubemq-web/src/index.tsx | 11 -
tubemq-web/src/pages/Broker/commonModal.tsx | 274 ------
tubemq-web/src/pages/Broker/detail.tsx | 378 --------
tubemq-web/src/pages/Broker/index.less | 9 -
tubemq-web/src/pages/Broker/index.tsx | 280 ------
tubemq-web/src/pages/Broker/query.tsx | 128 ---
tubemq-web/src/pages/Cluster/index.less | 0
tubemq-web/src/pages/Cluster/index.tsx | 143 ----
tubemq-web/src/pages/Issue/consumeGroupDetail.tsx | 95 ---
tubemq-web/src/pages/Issue/index.less | 0
tubemq-web/src/pages/Issue/index.tsx | 98 ---
tubemq-web/src/pages/NotFound/index.tsx | 5 -
tubemq-web/src/pages/Topic/commonModal.tsx | 349 --------
tubemq-web/src/pages/Topic/detail.tsx | 510 -----------
tubemq-web/src/pages/Topic/index.less | 9 -
tubemq-web/src/pages/Topic/index.tsx | 279 ------
tubemq-web/src/pages/Topic/query.tsx | 180 ----
tubemq-web/src/react-app-env.d.ts | 1 -
tubemq-web/src/router.tsx | 55 --
tubemq-web/src/routes/index.tsx | 37 -
tubemq-web/src/serviceWorker.ts | 146 ----
tubemq-web/src/setupProxy.js | 12 -
tubemq-web/src/store/global.ts | 30 -
tubemq-web/src/typings/index.ts | 1 -
tubemq-web/src/typings/router.ts | 14 -
tubemq-web/src/utils/index.ts | 45 -
tubemq-web/tsconfig.json | 33 -
tubemq-web/tsconfig.paths.json | 8 -
150 files changed, 1154 insertions(+), 8192 deletions(-)
delete mode 100644 DISCLAIMER
create mode 100644 DISCLAIMER-WIP
delete mode 100644 bin/broker.sh
delete mode 100644 bin/master.sh
rename bin/{tubemq => tubemq.sh} (100%)
delete mode 100644 resources/assets/public/css/fonts/icon.eot
delete mode 100644 resources/assets/public/css/fonts/icon.ttf
delete mode 100644 resources/assets/public/css/fonts/icon.woff
delete mode 100644
tubemq-core/src/main/java/org/apache/tubemq/corebase/utils/MapBackedSet.java
copy
tubemq-core/src/test/java/org/apache/tubemq/corebase/utils/{AddressUtilsTest.java
=> ConcurrentHashSetTest.java} (50%)
delete mode 100644 tubemq-manager/READMe.md
delete mode 100755 tubemq-manager/bin/start-manager.sh
delete mode 100755 tubemq-manager/bin/stop-manager.sh
delete mode 100644 tubemq-manager/conf/logback.xml
delete mode 100644 tubemq-manager/pom.xml
delete mode 100644 tubemq-manager/src/main/assembly/assembly.xml
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/TubeMQManager.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/controller/ManagerControllerAdvice.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/controller/TubeResult.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/controller/cluster/ClusterController.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/controller/topic/TopicController.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/entry/NodeEntry.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/entry/TopicEntry.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/entry/TopicStatus.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/exceptions/TubeMQManagerException.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/repository/NodeRepository.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/repository/TopicRepository.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/service/NodeService.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/service/TopicBackendWorker.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/service/TopicFuture.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/service/TubeHttpConst.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/service/tube/TubeHttpBrokerInfoList.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/service/tube/TubeHttpResponse.java
delete mode 100644
tubemq-manager/src/main/java/org/apache/tubemq/manager/service/tube/TubeHttpTopicInfoList.java
delete mode 100644 tubemq-manager/src/main/resources/application.properties
delete mode 100644
tubemq-manager/src/test/java/org/apache/tubemq/manager/controller/TestBusinessController.java
delete mode 100644
tubemq-manager/src/test/java/org/apache/tubemq/manager/controller/TestClusterController.java
delete mode 100644
tubemq-manager/src/test/java/org/apache/tubemq/manager/repository/TestBusinessRepository.java
delete mode 100644
tubemq-manager/src/test/java/org/apache/tubemq/manager/service/tube/TestTubeHttpBrokerResponse.java
delete mode 100644
tubemq-manager/src/test/java/org/apache/tubemq/manager/service/tube/TestTubeHttpTopicInfoList.java
create mode 100644
tubemq-server/src/main/java/org/apache/tubemq/server/tools/CliUtils.java
delete mode 100644
tubemq-server/src/main/java/org/apache/tubemq/server/tools/ToolUtils.java
delete mode 100644 tubemq-web/.env
delete mode 100644 tubemq-web/.eslintignore
delete mode 100644 tubemq-web/.eslintrc
delete mode 100644 tubemq-web/.gitignore
delete mode 100644 tubemq-web/.prettierrc
delete mode 100644 tubemq-web/.stylelintrc
delete mode 100644 tubemq-web/README.md
delete mode 100644 tubemq-web/config-overrides.js
delete mode 100644 tubemq-web/mock/_constant.js
delete mode 100644 tubemq-web/mock/app.js
delete mode 100644 tubemq-web/package.json
delete mode 100644 tubemq-web/public/favicon.ico
delete mode 100644 tubemq-web/public/index.html
delete mode 100644 tubemq-web/public/logo192.png
delete mode 100644 tubemq-web/public/logo512.png
delete mode 100644 tubemq-web/public/manifest.json
delete mode 100644 tubemq-web/public/robots.txt
delete mode 100644 tubemq-web/src/components/Breadcrumb/index.less
delete mode 100644 tubemq-web/src/components/Breadcrumb/index.tsx
delete mode 100644 tubemq-web/src/components/Layout/index.less
delete mode 100644 tubemq-web/src/components/Layout/index.tsx
delete mode 100644 tubemq-web/src/components/Modalx/index.less
delete mode 100644 tubemq-web/src/components/Modalx/index.tsx
delete mode 100644 tubemq-web/src/components/Tablex/index.less
delete mode 100644 tubemq-web/src/components/Tablex/index.tsx
delete mode 100644 tubemq-web/src/components/Tablex/tableFilterHelper.ts
delete mode 100644 tubemq-web/src/components/TitleWrap/index.less
delete mode 100644 tubemq-web/src/components/TitleWrap/index.tsx
delete mode 100644 tubemq-web/src/components/index.tsx
delete mode 100644 tubemq-web/src/configs/index.ts
delete mode 100644 tubemq-web/src/configs/menus/index.tsx
delete mode 100644 tubemq-web/src/constants/broker.ts
delete mode 100644 tubemq-web/src/constants/person.ts
delete mode 100644 tubemq-web/src/constants/topic.ts
delete mode 100644 tubemq-web/src/context/globalContext.ts
delete mode 100644 tubemq-web/src/defaultSettings.js
delete mode 100644 tubemq-web/src/hooks/index.ts
delete mode 100644 tubemq-web/src/index.tsx
delete mode 100644 tubemq-web/src/pages/Broker/commonModal.tsx
delete mode 100644 tubemq-web/src/pages/Broker/detail.tsx
delete mode 100644 tubemq-web/src/pages/Broker/index.less
delete mode 100644 tubemq-web/src/pages/Broker/index.tsx
delete mode 100644 tubemq-web/src/pages/Broker/query.tsx
delete mode 100644 tubemq-web/src/pages/Cluster/index.less
delete mode 100644 tubemq-web/src/pages/Cluster/index.tsx
delete mode 100644 tubemq-web/src/pages/Issue/consumeGroupDetail.tsx
delete mode 100644 tubemq-web/src/pages/Issue/index.less
delete mode 100644 tubemq-web/src/pages/Issue/index.tsx
delete mode 100644 tubemq-web/src/pages/NotFound/index.tsx
delete mode 100644 tubemq-web/src/pages/Topic/commonModal.tsx
delete mode 100644 tubemq-web/src/pages/Topic/detail.tsx
delete mode 100644 tubemq-web/src/pages/Topic/index.less
delete mode 100644 tubemq-web/src/pages/Topic/index.tsx
delete mode 100644 tubemq-web/src/pages/Topic/query.tsx
delete mode 100644 tubemq-web/src/react-app-env.d.ts
delete mode 100644 tubemq-web/src/router.tsx
delete mode 100644 tubemq-web/src/routes/index.tsx
delete mode 100644 tubemq-web/src/serviceWorker.ts
delete mode 100644 tubemq-web/src/setupProxy.js
delete mode 100644 tubemq-web/src/store/global.ts
delete mode 100644 tubemq-web/src/typings/index.ts
delete mode 100644 tubemq-web/src/typings/router.ts
delete mode 100644 tubemq-web/src/utils/index.ts
delete mode 100644 tubemq-web/tsconfig.json
delete mode 100644 tubemq-web/tsconfig.paths.json
