opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-29 04:13:00 +08:00
Code Issues Packages Projects Releases Wiki Activity
9,189 Commits 72 Branches 40 Tags
develop
Commit Graph

260 Commits

Author SHA1 Message Date
zhangjidi2016 0ff882bd4d [ISSUE #2801]Fix NamesrvAddr connot set in Producer 2021-04-14 11:16:25 +08:00
许晓东 2d18e50668 Print InterruptedException message 2021-02-23 16:35:32 +08:00
许晓东 58cbf596ab recover the property key of group suffix enable 2021-01-21 21:36:58 +08:00
许晓东 32881d466e add the property of benchmark producer that specifies how many messages to send 2021-01-21 21:13:16 +08:00
许晓东 7006d3a8db benchmark consumer isSuffixEnable default value set [false] and update help info 2021-01-18 13:06:48 +08:00
RongtongJin f35cafe128 [maven-release-plugin] prepare for next development iteration 2020-12-08 18:17:12 +08:00
RongtongJin 39bb9386f1 [maven-release-plugin] prepare release rocketmq-all-4.8.0 2020-12-08 18:16:49 +08:00
Git_Yang ac356f11a3 [ISSUE #2412] Support to add TAG when producing message 2020-12-04 15:29:35 +08:00
张旭 3be7033a16 [ISSUE #2146] Add benchmark shutdown script, add more print info, add consumer threand count command option (#2150) 
Co-authored-by: zhangxu16 <zhangxu16@xiaomi.com>
 2020-10-20 08:39:36 +08:00
张旭 f58dbc3eda [ISSUE #2300] Enhancement: Benchmark support acl and msg trace (#2301) 
* [Benchmark]Support acl, add msgTraceEnable option for producer and consumer, fix Algorithm HmacSHA1 not available using openjdk

* add apache header

* add aclEnable option
 2020-09-25 20:44:14 +08:00
vongosling 3e5008f288 refactor(build): Remove duplicated logback-core dependency and update some modules to 1.8 compiler lever 2020-07-29 14:12:13 +08:00
RongtongJin fac30c3596 [maven-release-plugin] prepare for next development iteration 2020-06-24 14:05:55 +08:00
RongtongJin 9f95a972e1 [maven-release-plugin] prepare release rocketmq-all-4.7.1 2020-06-24 14:05:32 +08:00
rongtongjin 3974677f04 [maven-release-plugin] prepare for next development iteration 2020-03-05 19:07:09 +08:00
rongtongjin 8ef01a6c63 [maven-release-plugin] prepare release rocketmq-all-4.7.0 2020-03-05 19:06:47 +08:00
rongtongjin dd94362257 [maven-release-plugin] prepare for next development iteration 2020-01-20 22:11:43 +08:00
rongtongjin 73bb4b402a [maven-release-plugin] prepare release rocketmq-all-4.6.1 2020-01-20 22:11:21 +08:00
rongtongjin 25c4e1ccb3 Merge branch master into develop 2020-01-20 21:49:07 +08:00
huangli 9da19d2e37 optimise benchmark consumer, add consume fail rate option 2020-01-20 20:53:26 +08:00
Heng Du f1b856a091 feat(pullconsumer) add pull sys flag (#1658) 
feat(lite_pull_consumer) add support for consume from where

test(pull_consumer) add unit test for compute from where

test(PullSysFlag) add lite pull sys flag unit test

feat(pull_consumer) add the verification of ConsumerFromWhere value
 2019-12-27 20:11:43 +08:00
huangli 34c3454957 Optimise tx benchmark producer (#1628) 2019-12-06 10:35:01 +08:00
ShannonDing c3b7d18603 [maven-release-plugin] prepare for next development iteration 2019-11-19 21:00:19 +08:00
ShannonDing d1b4e47c26 [maven-release-plugin] prepare release rocketmq-all-4.6.0 2019-11-19 20:59:56 +08:00
Heng Du e735fffe74 Merge pull request #1422 from qqeasonchen/rocketmq-dev-rpc 
[RIP-16]Support request/response pattern
 2019-11-14 15:53:00 +08:00
Heng Du 6a6f2e7d59 Merge pull request #1544 from areyouok/4.5.2.fix 
[ISSUE #1519]Optimise performance/stability of  transaction message
 2019-10-31 09:13:22 +08:00
qqeasonchen 4fa263f756 code style format 2019-10-16 17:34:56 +08:00
qqeasonchen f16fd08c5e rename REPLY_TO to REPLY_TO_CLIENT 2019-10-16 17:15:11 +08:00
qqeasonchen 18e44c2bbc remove reply interface in consumer 2019-10-12 16:53:54 +08:00
huangli df59df3790 Add -n (nameServer) option to benchmark consumer; Enable options(-n/-t/w/-s/-c/-r) to TransactionProducer 2019-10-12 15:58:46 +08:00
qqeasonchen 0c47fcf716 add recommend client configs in rpc mode 2019-09-26 21:19:48 +08:00
qqeasonchen c434ff432c Merge branch 'develop' of https://github.com/apache/rocketmq into rocketmq-dev-rpc 2019-09-24 20:29:19 +08:00
qqeasonchen 28936fa12a add reply interface to consumer 2019-09-23 20:07:41 +08:00
qqeasonchen ec1f9266d2 optimize request/response examples 2019-09-18 10:48:15 +08:00
qqeasonchen 53a6955e5b [RIP-16]change the way creating reply message 2019-09-12 10:40:21 +08:00
qqeasonchen cc0a5e391e code format 2019-09-11 19:47:47 +08:00
qqeasonchen 7e221e51e8 add example of request-response model 2019-09-11 19:40:04 +08:00
Heng Du 9edeb4ecd8 Merge pull request #1386 from apache/litePullConsumer 
[ISSUE #1388]Add lite pull consumer support for RocketMQ
 2019-08-22 21:07:18 +08:00
King 4a4a464b25 Polish lite pull consumer and fix bug (#1402) 
1. Fix the problem of seek function blocking.
2. Fix shutdown function bug.
3. Make the code cleaner
4. Add unit test.
5. Fix seek bug
 2019-08-21 09:23:59 +08:00
King cfca4401d5 Polish LitePullConsumer (#1395) 
* fix unsubscribe code

* fix commit consumed offset

* fix commit consumed offset

* fix commit consumed offset

* fix commit consumed offset

* polish commit consumed offset

* pass checkstyle

* pass checkstyle

* polish LiteMQPullConsumer

* add flow control and polish commit logic

* fix bug

* polish code

* fix commit consumed offset back

* refactor litePullConsumer

* development save

* development save

* Refactor DefaultLitePullConsumer and DefaultLitePullConsumerImpl.

* Polish lite pull consumer

* polish lite pull consumer

* polish lite pull consumer

* fix seek

* fix seek function

* polish lite pull consumer

* add apache header

* add test

* polish test

* Make broadcast model work for litePullConsumer

* Revert example/broadcast/PushConsumer.java

* Add delay time when no new message

* Enable long polling mode

* Fix subscribe bug when rebalance

* Delete useless consumeMessageHook

* Implement TopicMessageQueueChangeListener interface

* Lite pull consumer support namespace

* Make sql92 filter work

* 1. Add javadoc for lite pull consumer.
2. Polish lite pul consumer parameters

* Modify lite pull consumer example

* Add apache header for LitePullConsumerAssign example.

* Add unit test for lite pull consumer

* Fix typo
 2019-08-19 14:57:16 +08:00
Heng Du ddb07ab13c Deprecated the DefaulteMQPull consumer (#1387) 2019-08-14 17:27:31 +08:00
King 46288abb33 Polish lite pull consumer and fix bug (#1373) 
* fix unsubscribe code

* fix commit consumed offset

* fix commit consumed offset

* fix commit consumed offset

* fix commit consumed offset

* polish commit consumed offset

* pass checkstyle

* pass checkstyle

* polish LiteMQPullConsumer

* add flow control and polish commit logic

* fix bug

* polish code

* fix commit consumed offset back

* refactor litePullConsumer

* development save

* development save

* Refactor DefaultLitePullConsumer and DefaultLitePullConsumerImpl.

* Polish lite pull consumer

* polish lite pull consumer

* polish lite pull consumer

* fix seek

* fix seek function

* polish lite pull consumer

* add apache header

* add test

* polish test

* Make broadcast model work for litePullConsumer

* Revert example/broadcast/PushConsumer.java

* Add delay time when no new message

* Enable long polling mode

* Fix subscribe bug when rebalance

* Delete useless consumeMessageHook
 2019-08-09 11:26:53 +08:00
King 9c3b26cfd3 Polish lite pull consumer (#1359) 
* fix unsubscribe code

* fix commit consumed offset

* fix commit consumed offset

* fix commit consumed offset

* fix commit consumed offset

* polish commit consumed offset

* pass checkstyle

* pass checkstyle

* polish LiteMQPullConsumer

* add flow control and polish commit logic

* fix bug

* polish code

* fix commit consumed offset back

* refactor litePullConsumer

* development save

* development save

* Refactor DefaultLitePullConsumer and DefaultLitePullConsumerImpl.

* Polish lite pull consumer

* polish lite pull consumer

* polish lite pull consumer

* fix seek

* fix seek function

* polish lite pull consumer

* add apache header

* add test

* polish test
 2019-08-02 10:34:06 +08:00
zongtanghu 90ae116798 [maven-release-plugin] prepare for next development iteration 2019-08-01 23:25:38 +08:00
zongtanghu d63678dc50 [maven-release-plugin] prepare release rocketmq-all-4.5.2 2019-08-01 23:25:12 +08:00
King 83098eb604 Polish lite pull consumer (#1349) 
* fix unsubscribe code

* fix commit consumed offset

* fix commit consumed offset

* fix commit consumed offset

* fix commit consumed offset

* polish commit consumed offset

* pass checkstyle

* pass checkstyle

* polish LiteMQPullConsumer

* add flow control and polish commit logic

* fix bug

* polish code

* fix commit consumed offset back

* refactor litePullConsumer

* development save

* development save

* Refactor DefaultLitePullConsumer and DefaultLitePullConsumerImpl.

* Polish lite pull consumer

* polish lite pull consumer

* polish lite pull consumer

* fix seek
 2019-07-30 10:59:13 +08:00
King 62ca947a45 Polish LitePullConsumer (#1332) 
* fix unsubscribe code

* fix commit consumed offset

* fix commit consumed offset

* fix commit consumed offset

* fix commit consumed offset

* polish commit consumed offset

* pass checkstyle

* pass checkstyle
 2019-07-19 11:19:07 +08:00
duhenglucky 11b686e477 Add lite pull consumer example 2019-07-17 14:33:29 +08:00
ymwneu 5b29b73cc8 Set auto commit (#914) 2019-07-11 18:47:40 +08:00
ShannonDing 52005aee90 [maven-release-plugin] prepare for next development iteration 2019-05-21 11:19:03 +08:00
ShannonDing 639cb5c299 [maven-release-plugin] prepare release rocketmq-all-4.5.1 2019-05-21 11:18:41 +08:00