- 24 6月, 2020 2 次提交
-
-
由 RongtongJin 提交于
-
由 RongtongJin 提交于
-
- 05 3月, 2020 2 次提交
-
-
由 rongtongjin 提交于
-
由 rongtongjin 提交于
-
- 20 1月, 2020 3 次提交
-
-
由 rongtongjin 提交于
-
由 rongtongjin 提交于
-
由 huangli 提交于
-
- 27 12月, 2019 1 次提交
-
-
由 Heng Du 提交于
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
-
- 06 12月, 2019 1 次提交
-
-
由 huangli 提交于
-
- 19 11月, 2019 2 次提交
-
-
由 ShannonDing 提交于
-
由 ShannonDing 提交于
-
- 16 10月, 2019 2 次提交
-
-
由 qqeasonchen 提交于
-
由 qqeasonchen 提交于
-
- 12 10月, 2019 2 次提交
-
-
由 qqeasonchen 提交于
-
由 huangli 提交于
Add -n (nameServer) option to benchmark consumer; Enable options(-n/-t/w/-s/-c/-r) to TransactionProducer
-
- 26 9月, 2019 1 次提交
-
-
由 qqeasonchen 提交于
-
- 23 9月, 2019 1 次提交
-
-
由 qqeasonchen 提交于
-
- 18 9月, 2019 1 次提交
-
-
由 qqeasonchen 提交于
-
- 12 9月, 2019 1 次提交
-
-
由 qqeasonchen 提交于
-
- 11 9月, 2019 2 次提交
-
-
由 qqeasonchen 提交于
-
由 qqeasonchen 提交于
-
- 22 8月, 2019 1 次提交
-
-
由 陈永明 提交于
* Remove the useless files * Replace PermSize with MetaspaceSize, details see http://openjdk.java.net/jeps/122 * Update DLedgerCommitLog.java (#1145) Delete useless code * Remove the duplicate content * Polish the comment (#1107) * Minor Typo fix (#860) * [ISSUE #1082] Fix disconnection of HA (#1083) * fixed the text description in chinese doc (#1339) * fix /dev/shm not found on some OSs (#1345) * Refactor the protection logic when pulling * change the MQVersion variable to rocketmq 4.5.2 version; * Minor polish * Fix the wrong package name * [maven-release-plugin] prepare release rocketmq-all-4.5.2 * [maven-release-plugin] prepare for next development iteration * [RIP-15]Add Ipv6 support for RocketMQ
-
- 21 8月, 2019 1 次提交
-
-
由 King 提交于
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
-
- 19 8月, 2019 1 次提交
-
-
由 King 提交于
* 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
-
- 14 8月, 2019 1 次提交
-
-
由 Heng Du 提交于
-
- 09 8月, 2019 1 次提交
-
-
由 King 提交于
* 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
-
- 02 8月, 2019 1 次提交
-
-
由 King 提交于
* 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
-
- 01 8月, 2019 2 次提交
-
-
由 zongtanghu 提交于
-
由 zongtanghu 提交于
-
- 30 7月, 2019 1 次提交
-
-
由 King 提交于
* 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
-
- 19 7月, 2019 1 次提交
-
-
由 King 提交于
* 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
-
- 17 7月, 2019 1 次提交
-
-
由 duhenglucky 提交于
-
- 11 7月, 2019 1 次提交
-
-
由 ymwneu 提交于
-
- 21 5月, 2019 2 次提交
-
-
由 ShannonDing 提交于
-
由 ShannonDing 提交于
-
- 29 3月, 2019 2 次提交
-
-
由 wlliqipeng 提交于
-
由 wlliqipeng 提交于
-
- 28 3月, 2019 2 次提交
- 17 1月, 2019 1 次提交
-
-
由 duhenglucky 提交于
-