1. 11 5月, 2020 1 次提交
  2. 16 10月, 2019 2 次提交
  3. 15 10月, 2019 1 次提交
  4. 14 10月, 2019 2 次提交
  5. 04 10月, 2019 1 次提交
  6. 02 10月, 2019 1 次提交
  7. 30 9月, 2019 2 次提交
  8. 29 9月, 2019 1 次提交
  9. 28 9月, 2019 1 次提交
  10. 27 9月, 2019 1 次提交
  11. 26 9月, 2019 1 次提交
  12. 25 9月, 2019 1 次提交
  13. 20 9月, 2019 1 次提交
  14. 19 9月, 2019 1 次提交
  15. 18 9月, 2019 1 次提交
  16. 17 9月, 2019 3 次提交
  17. 16 9月, 2019 3 次提交
  18. 04 9月, 2019 3 次提交
  19. 01 9月, 2019 1 次提交
  20. 29 8月, 2019 1 次提交
  21. 28 8月, 2019 3 次提交
  22. 22 8月, 2019 5 次提交
  23. 21 8月, 2019 1 次提交
  24. 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
  25. 14 8月, 2019 1 次提交