- 28 9月, 2019 1 次提交
-
-
由 von gosling 提交于
[ISSUE 1491] Ignore IllegalStateException when remove shutdown hook
-
- 27 9月, 2019 1 次提交
-
-
由 rongtongjin 提交于
If shutdown of the JVM in progress already, we don't need to remove the hook, it will be removed by the JVM. Close #1491
-
- 26 9月, 2019 1 次提交
-
-
由 Heng Du 提交于
[ISSUE #1483] fix bug in QueryMsgByIdSubCommand print OffsetID twice
-
- 25 9月, 2019 1 次提交
-
-
由 yuanjunhui 提交于
-
- 20 9月, 2019 1 次提交
-
-
由 Heng Du 提交于
Fix(client): lite pull consumer lost messages in some scenario
-
- 19 9月, 2019 1 次提交
-
-
由 Heng Du 提交于
[ISSUE #1108] Fix concurrent problems with client-side connection creation
-
- 18 9月, 2019 1 次提交
-
-
由 rongtongjin 提交于
In jepsen test, consumer lost messages when using the lite pull consumer. This is due to the incorrect setting of consume offset. Delete the wrong code to make it correct.
-
- 17 9月, 2019 3 次提交
-
-
由 von gosling 提交于
-
由 von gosling 提交于
-
由 von gosling 提交于
Add PhysicMsgTimestamp update logic when replicas recovering from the abnormal case. Closes #1456
-
- 16 9月, 2019 3 次提交
-
-
由 liuruiyiyang 提交于
-
由 duhenglucky 提交于
-
由 duhenglucky 提交于
-
- 04 9月, 2019 3 次提交
-
-
由 KangZhiDong 提交于
-
由 Heng Du 提交于
[ISSUES #1439]fix transaction typo
-
由 wangyufan 提交于
-
- 01 9月, 2019 1 次提交
-
-
由 KangZhiDong 提交于
-
- 28 8月, 2019 3 次提交
-
-
由 von gosling 提交于
This reverts commit 83de262c.
-
由 zhangzhikai 提交于
-
由 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.
-
- 22 8月, 2019 4 次提交
-
-
由 Heng Du 提交于
[ISSUE #1388]Add lite pull consumer support for RocketMQ
-
由 King 提交于
* Add unit test for lite pull consumer. * Add synchronized to poll function.
-
由 vongosling 提交于
-
由 vongosling 提交于
-
- 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 2 次提交
-
-
由 Heng Du 提交于
-
由 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
-
- 09 8月, 2019 3 次提交
-
-
由 huzongtang 提交于
-
-
由 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 提交于
-
- 31 7月, 2019 6 次提交
-
-
由 vongosling 提交于
-
由 vongosling 提交于
-
由 huzongtang 提交于
-
由 dinglei 提交于
-
由 vongosling 提交于
-
由 vongosling 提交于
-