1. 05 3月, 2020 2 次提交
  2. 20 1月, 2020 3 次提交
  3. 27 12月, 2019 1 次提交
    • H
      feat(pullconsumer) add pull sys flag (#1658) · f1b856a0
      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
      f1b856a0
  4. 06 12月, 2019 1 次提交
  5. 19 11月, 2019 2 次提交
  6. 16 10月, 2019 2 次提交
  7. 12 10月, 2019 2 次提交
  8. 26 9月, 2019 1 次提交
  9. 23 9月, 2019 1 次提交
  10. 18 9月, 2019 1 次提交
  11. 12 9月, 2019 1 次提交
  12. 11 9月, 2019 2 次提交
  13. 22 8月, 2019 1 次提交
    • [RIP-15]Add Ipv6 support for RocketMQ (#1352) · c7c9601d
      陈永明 提交于
      * 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
      c7c9601d
  14. 21 8月, 2019 1 次提交
  15. 19 8月, 2019 1 次提交
    • K
      Polish LitePullConsumer (#1395) · cfca4401
      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
      cfca4401
  16. 14 8月, 2019 1 次提交
  17. 09 8月, 2019 1 次提交
    • K
      Polish lite pull consumer and fix bug (#1373) · 46288abb
      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
      46288abb
  18. 02 8月, 2019 1 次提交
    • K
      Polish lite pull consumer (#1359) · 9c3b26cf
      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
      9c3b26cf
  19. 01 8月, 2019 2 次提交
  20. 30 7月, 2019 1 次提交
    • K
      Polish lite pull consumer (#1349) · 83098eb6
      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
      83098eb6
  21. 19 7月, 2019 1 次提交
    • K
      Polish LitePullConsumer (#1332) · 62ca947a
      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
      62ca947a
  22. 17 7月, 2019 1 次提交
  23. 11 7月, 2019 1 次提交
  24. 21 5月, 2019 2 次提交
  25. 29 3月, 2019 2 次提交
  26. 28 3月, 2019 2 次提交
  27. 17 1月, 2019 2 次提交
  28. 07 1月, 2019 1 次提交