* fix(common): fix the issue#5039
1. fix the issue#5039 by init the local host name when BrokerIdentity
class loading to avoid the InetAddress#getLocalHost() be called too many
times.
* Update common/src/main/java/org/apache/rocketmq/common/BrokerIdentity.java
Co-authored-by: Oliver <wqdyxnbd@163.com>
* fix(common): add import of StringUtils in class: BrokerIdentity
1. add import of StringUtils in class: BrokerIdentity
* rerun
Co-authored-by: Oliver <wqdyxnbd@163.com>
* optimize the memory usage in DefaultMappedFile:
use AtomicIntegerFieldUpdater instead of AtomicInteger
* fix code bug:
if the initial cursor of listIterator equals zero,
the previous element will always null.
* modify constant name
* fix excessive nesting
* Update client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
* update maven-surefire-plugin.version from 2.19.1 to 2.22.1
* Revert "update maven-surefire-plugin.version from 2.19.1 to 2.22.1"
This reverts commit 37fabe6e78.
* Code Style: fix warn info from the code detector.
* fix checkstyle: not use '*' for import.
* Fix code style in any net modules.
* change method name from topicRouteDataIsChange to topicRouteDataChanged in TopicRouteData.java
* revert executeInvokeCallback method
* Fix grammar issues
Co-authored-by: shanpengyu <shanpengyu@bytedance.com>
Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
Co-authored-by: Zhanhui Li <lizhanhui@apache.org>
* optimize the memory usage in DefaultMappedFile:
use AtomicIntegerFieldUpdater instead of AtomicInteger
* fix code bug:
if the initial cursor of listIterator equals zero,
the previous element will always null.
* modify constant name
* fix excessive nesting
* Update client/src/main/java/org/apache/rocketmq/client/impl/factory/MQClientInstance.java
* update maven-surefire-plugin.version from 2.19.1 to 2.22.1
* Revert "update maven-surefire-plugin.version from 2.19.1 to 2.22.1"
This reverts commit 37fabe6e78.
* Code Style: fix warn info from the code detector.
* fix checkstyle: not use '*' for import.
Co-authored-by: shanpengyu <shanpengyu@bytedance.com>
Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
* Rule out tests that are flaky. Aka they failed to pass 64 sequential and concurrent runs
* Change default log root directory for tests
* Follow test encyclopedia
* Fix test cases, allowing OS pick up available port to listen to
* Add sha256
* Use pull_request
* Support build with Bazel (#4865)
* Support build with Bazel, fixing tests to make them capable of running in concurrency and hermetic.
* Make test cases capable of running in parallel. (#4874)
* feat(controller): add elect policy
1. add epoch and maxOffset in heartbeat.
2. refactor elect logic, now we
elect a new master by elect policy(can expand).
3. add some unit tests
* refactor(controller): refactor some code and format some code
1. refactor some code and format some code
* fix typo in ReplicasInfoManager
1. fix typo in ReplicasInfoManager
* fix wrong method call in ReplicasManagerTest#before
1.fix wrong method call in ReplicasManagerTest#before
* fix wrong call in ReplicasManagerTest#before
1. fix wrong call in ReplicasManagerTest#before
* fix(controller): fix the bug about ReElectMaster
1. fix the bug about ReElectMaster
2. fix some typo
* style(controller): fix typo by checkstyle
1. fix typo by checkstyle
* test(broker): fix invalid usage of "any()" in DLedegerControllerTest#before
1. fix invalid usage of "any()" in DLedegerControllerTest#before
* fix(controller): fix some wrong usage in test
1. fix some wrong usage in test
2. refactor some field type to avoid NPE
* fix:when broker is down,async send model can not retry
* fix Issue #3556
* fix Issue #3556
* fix Issue #3556
* fix Issue #3556
* async send model success retry when occurs Exception
* test case testSendMessageAsync_WithException
* modify test case testSendMessageAsync_WithException
* adding exception message with broker addr when occuring broker connect
timeout
* repair code style
* in async mode,set ThreadExecutorPool AbortPolicy
* Optimize asynchronous send timeout logic code
* Adjusting log information
* Delete SendMessageProcessor.java
* 恢复上一个版本
* namesrv nearby route
* Revert to previous version code
* add lisence header to Network.java
* code style
* 根据broker和client配置的标识返回路由信息
* Delete greetings.yml
* Delete .gitignore
* reset previous version
* reset to previous version
* code style
* Namesrv nearby route implements all by RPCHook
* reset to prevous version
* ServiceProvider return to original position
* Nearby route make the code clear
* revert to ori version
* reset to ori version
* reset to ori version
* reset to ori version
* Keep same as the official version
* Keep same as the official version
* Keep same as the official version
Co-authored-by: sunhangda <sunhangda@lixiang.com>
* Replace scheduled message in Pop with timer message.
* add unit test.
* refactor
* WIP
* improve unit test
* improve unit test
* improve unit test
* fix unnecessary stubbing problem.
* fix misspelling 'replase' in doc.
* refactor and rebuild
* fix the bug of #4702
Co-authored-by: 傅冲 <yubao.fyb@alibaba-inc.com>
* [ISSUE #4257] Verify that the value of the permission is valid when updating the topic/broker config
* delete useless import
Co-authored-by: wangfan <wangfan8@xiaomi.com>
lizhimins