Commit Graph
570 Commits
Author SHA1 Message Date
zhiliatom b944cd881b [ISSUE 5265] Adjust nested logic to reduce nums of check in queryMsgByUniqKey (#5266) 2022-10-11 11:25:39 +08:00
5be473a690 [ISSUE #4658] remove redundant logic (#5245)
* [ISSUE #4658] remove redundant logic

* Update client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java

* Update client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java

Co-authored-by: lizhimins <707364882@qq.com>

* Update client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java

Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
Co-authored-by: lizhimins <707364882@qq.com>
2022-10-08 14:25:49 +08:00
Nowinkey 6f8568ea50 style(client):Enable checkstyle for test code (#5211) 2022-09-29 10:25:47 +08:00
Oliver 198f786ee3 [ISSUE #5152] Change the error log level to error (#5153) 2022-09-28 14:25:50 +08:00
lizhimins b8607d917c [ISSUE #5095] Support socks proxy in remoting client (#5123) 2022-09-28 10:22:55 +08:00
RapperCLandchenyong adb83ca096 [ISSUE #5179] Math.abs() method call redundant, judgment and repeated assignment (#5181)
* remove the abs method

* Judgment optimization

* Reduce duplicate settings

Co-authored-by: chenyong <chenyong@highlight.mobi>
2022-09-23 21:06:28 +08:00
RapperCLandchenyong 590a680c38 [ISSUE #5151]Reduce redundant for loops (#5154)
* [ISSUE #5151]Reduce redundant for loops

* [ISSUE #5151] code re-format

Co-authored-by: chenyong <chenyong@highlight.mobi>
2022-09-23 17:15:17 +08:00
hill ac82378aea [maven-release-plugin] prepare for next development iteration 2022-09-19 10:27:17 +08:00
hill f3e113cb1f [maven-release-plugin] prepare release rocketmq-all-5.0.0 2022-09-19 10:26:58 +08:00
Aaron Ai 1b011c1f50 [ISSUE #5108] Bump checkstyle to 3.2.0 (#5109)
* Bump checkstyle to 3.2.0

* Fix checkstyle
2022-09-19 10:10:29 +08:00
echooymxq c820a68296 [ISSUE #5043] Fix broker logger replaced by ClientLogger. (#5044) 2022-09-13 20:11:25 +08:00
8357cff101 [ISSUE #5002]Fix code style in any net modules. (#4989)
* 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>
2022-09-05 13:38:26 +08:00
Shengmin Wang 3739327915 [ISSUE#4599] Optimize enableBackpressureForAsyncMode not relying on NettyRemoting (#4601)
* optimize backpressure, add on-going thread nums and message size limit

* modify send mechanism, reserve threadpool in backpressure mode

* modify library reference style

* modify code style

* modify default semaphoreAsyncSize as 100M

* move semaphore to DefaultMQProducerImpl, expose the integer value in DefaultMQProducer

* modify code style

* add blank to trigger CI test

* add check condition, keep timeout - costTime is active

* add semaphoreAsyncSendNum and semaphoreAsyncSendSize limit

* add semaphoreAsyncSendNum and semaphoreAsyncSendSize limit
2022-09-05 11:46:12 +08:00
Aaron Ai ec0426ca0e Fix DefaultLitePullConsumerTest#testConsumerCommitSyncWithMQOffset (#4973) 2022-09-02 15:00:09 +08:00
74bae190d5 fix code style in MQClientInstance (#4961)
* 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>
2022-09-01 11:20:24 +08:00
zhaows c6820f23eb send async,time calculation rules Multiple method patches (#4881)
* Clear out meaningless changes

* merge upstream/dev

* merge upstream/dev

* send async,time calculation rules Multiple method patches

* Clear out meaningless changes

* merge upstream/dev

* merge upstream/dev

* send async,time calculation rules Multiple method patches
2022-09-01 09:44:27 +08:00
a940d96af0 Fix excessive nesting in MQClientInstance#sendHeartbeatToAllBroker (#4932)
* fix excessive nesting

Co-authored-by: shanpengyu <shanpengyu@bytedance.com>
Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
2022-08-31 16:20:12 +08:00
Aaron Ai f23fdbe016 Replace findbugs by spotbugs (#4931) 2022-08-30 17:45:56 +08:00
Zhanhui Li aae7b37d04 [ISSUE 4915] Identify flaky tests (#4919)
* 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
2022-08-29 19:52:53 +08:00
Shengmin Wang 244959ca51 set requestHeader setZeroIfNotFound false (#4910) 2022-08-28 20:31:39 +08:00
mxsm a961d1b44a [ISSUE #4817] Add a command to clear broker data from controller for CLI (#4823) 2022-08-27 19:42:55 +08:00
echooymxq f7c2072a27 [ISSUE #4841] Fix the reply message is the original request msg. (#4896) 2022-08-27 11:00:20 +08:00
xiaoyi a1d2a73255 [ISSUE #4805]In the subscribe mode, user-defined MessageQueueListener is supported. At the same time, you can specify the offset that the MessageQueue will commit (#4820) 2022-08-25 09:08:23 +08:00
Zhanhui Li 3da7ea9c1b [Infra Improvement] Build And Run Unit Tests in Parallel (#4878)
* 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)
2022-08-24 20:53:30 +08:00
zhaows 9e4c624ea1 send async,time is not counted until the task is executed (#4839) 2022-08-23 19:00:58 +08:00
YangJodie 17634d3317 [ISSUE apache#4858] add consumer type check for message direct push 2022-08-23 18:52:10 +08:00
RongtongJin bbbb96e129 Revert "Support build with Bazel (#4865)"
This reverts commit ec8a93d2f7.
2022-08-23 14:29:46 +08:00
dinglei 2930994a37 [ISSUE #4584] Add new persist method to update consume offset to remote server. 2022-08-23 13:57:35 +08:00
Zhanhui Li ec8a93d2f7 Support build with Bazel (#4865)
* Support build with Bazel, fixing tests to make them capable of running in concurrency and hermetic.
2022-08-23 13:11:53 +08:00
lizhiboo dd87d90b29 [ISSUE #4776]Support tag in litepullconsumer assign mode (#4775)
* support tag for litepullconsumer at assign type

* support tag for litepullconsumer at assign mode

* with namespace

* fix typo

* add test case

* fix

* code style
2022-08-15 18:02:57 +08:00
caigy dbcd37cd39 [ISSUE #4815] fix reconsuming messages in POP mode taking at least 2min 2022-08-13 00:09:27 +08:00
sunhangdaandsunhangda 0375027b70 [ISSUE #4382]Namesrv nearby route (#4383)
* 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>
2022-08-11 17:31:45 +08:00
mxsm 06ca14a508 [ISSUE #4791] Add elect master command for admin CLI (#4798) 2022-08-11 10:06:46 +08:00
Aaron Ai 61b14c3f4e [ISSUE #4785] Enable misspell check GitHub Action (#4786)
* Enable misspell check GitHub Action

* Fix typo
2022-08-08 09:28:41 +08:00
rongtong 0b6563b58f Add getControllerConfig and updateControllerConfig command for admin CLI (#4793) 2022-08-07 15:28:51 +08:00
mxsmandAaron Ai b875b3309a [ISSUE #4709] fix method is on the same line as @Override annotation (#4717)
Co-authored-by: Aaron Ai <yangkun.ayk@gmail.com>
2022-08-01 20:42:34 +08:00
wangfanandwangfan e8fd55bb01 [ISSUE #4257] Verify that the value of the permission is valid when updating the topic/broker config (#4498)
* [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>
2022-07-31 16:40:29 +08:00
刘亚洲 7f97d5f86b Delete extra commas and format code 2022-07-22 14:43:30 +08:00
Heng Du efbc4a1fcc Merge pull request #4484 from apache/5.0.0-beta-dledger-controller
[RIP-44] Support DLedger Controller
2022-07-21 09:23:27 +08:00
chaiyx 1905756db2 [ISSUE #4062] pop consumer does not require static topic 2022-07-20 20:27:36 +08:00
RongtongJin dd09f2b782 Merge remote-tracking branch 'apache/develop' into 5.0.0-beta-dledger-controller
# Conflicts:
#	distribution/bin/mqshutdown
#	pom.xml
2022-07-20 10:53:39 +08:00
zhouxiang f51f9f657f Merge branch 'develop' into feature/grpc-develop-v2 2022-07-19 21:35:20 +08:00
zhouxiang ac6ccc5445 [ISSUE #3905] Support bname in protocol 2022-07-18 14:21:32 +08:00
Oliver c1b14b0dde Fix typo 2022-07-16 22:23:23 +08:00
cserwenanddengzhiwen1 00da3e7249 [ISSUE #4606] Build trace msgs for DefaultLitePullConsumer when poll is called
Co-authored-by: dengzhiwen1 <dengzhiwen1@xiaomi.com>
2022-07-15 17:33:54 +08:00
zhouxiang 9fbaced20f Merge branch 'develop' into feature/grpc-develop-v2 2022-07-14 14:15:30 +08:00
RongtongJin 8dfa8813c4 Merge remote-tracking branch 'apache/develop' into 5.0.0-beta-dledger-controller 2022-07-13 15:10:01 +08:00
Heng Du 10326b479a Merge pull request #4578 from apache/develop-merge-5.0.0
The code of 5.0.0-beta merge into develop branch
2022-07-13 14:54:23 +08:00
kaiyi.lk 4961620618 [ISSUE #3949] parameter validate 2022-07-13 11:32:57 +08:00
zhouxiang 2a089ffd39 [ISSUE #3906] Mark stream-related request by RequestType 2022-07-13 11:31:01 +08:00