1. 04 9月, 2019 1 次提交
  2. 28 8月, 2019 1 次提交
    • K
      [ISSUE 504] Polish 'No route info of this topic' exception (#1415) · 74ffae6d
      King 提交于
      * Polish 'no route info of this topic' exception.
      
      * Write exception to log
      
      * Modify logic that cannot connect to nameserver
      
      * Solve the problem that the regression test does not pass.
      
      * Adapt to lite pull consumer
      
      * Make checkNameServerSetting function private and change its name.
      74ffae6d
  3. 22 8月, 2019 4 次提交
  4. 21 8月, 2019 1 次提交
  5. 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
  6. 14 8月, 2019 2 次提交
    • H
      Deprecated the DefaulteMQPull consumer (#1387) · ddb07ab1
      Heng Du 提交于
      ddb07ab1
    • K
      Polish lite pull consumer (#1381) · c6096a14
      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
      c6096a14
  7. 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
  8. 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
  9. 01 8月, 2019 2 次提交
  10. 31 7月, 2019 6 次提交
  11. 30 7月, 2019 4 次提交
    • R
      fix /dev/shm not found on some OSs (#1345) · 7ac5ad37
      Rui Liu 提交于
      7ac5ad37
    • 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
    • Z
      Update concept.md (#1319) · e1b9a32d
      zhibo 提交于
      e1b9a32d
    • S
      fixed the text description in chinese doc (#1339) · 57e2959b
      skyline1688 提交于
      57e2959b
  12. 27 7月, 2019 1 次提交
  13. 24 7月, 2019 7 次提交
  14. 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
  15. 17 7月, 2019 1 次提交
  16. 15 7月, 2019 1 次提交
  17. 12 7月, 2019 2 次提交
  18. 11 7月, 2019 3 次提交