• 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
DefaultLitePullConsumer.java 12.2 KB