提交 · 9d18256c66752e57ef9da4d8d119d81b96c37688 · super-server / Rocketmq

27 9月, 2019 1 次提交

fix(trace):ignore IllegalStateException when remove shutdown hook · 9d18256c

由 rongtongjin 提交于 9月 27, 2019

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

9d18256c

26 9月, 2019 1 次提交
- H
  Merge pull request #1484 from ChaosYjh/QueryMsgById-branch · 203272c7
  由 Heng Du 提交于 9月 26, 2019
```
[ISSUE #1483] fix bug in QueryMsgByIdSubCommand print OffsetID twice
```
  203272c7
25 9月, 2019 1 次提交
- Y
  
  [ISSUE #1483] fix bug in QueryMsgByIdSubCommand print OffsetID twice · fb7a7e59
  由 yuanjunhui 提交于 9月 25, 2019
  
  fb7a7e59
20 9月, 2019 1 次提交
- H
  Merge pull request #1461 from RongtongJin/apache-develop · 61f4f99b
  由 Heng Du 提交于 9月 20, 2019
```
Fix(client): lite pull consumer lost messages in some scenario
```
  61f4f99b
19 9月, 2019 1 次提交
- H
  Merge pull request #1109 from zhanguohuang/develop-fix-NettyRemotingClient · c4d95fc9
  由 Heng Du 提交于 9月 19, 2019
```
[ISSUE #1108] Fix concurrent problems with client-side connection creation
```
  c4d95fc9
18 9月, 2019 1 次提交

Fix(client):fix the issue that lite pull consumer lost messages in some scenario · a3bab0eb

由 rongtongjin 提交于 9月 18, 2019

	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.

a3bab0eb

17 9月, 2019 3 次提交
- V
  
  docs( Configuration_Client.md): polish definite article and indefinite article · d71495a1
  由 von gosling 提交于 9月 17, 2019
  
  d71495a1
- V
  
  Update Configuration_Client.md · c7ec99cd
  由 von gosling 提交于 9月 17, 2019
  
  c7ec99cd
- V
  fix(replica): resolve abnormal slow recover · 523b60cf
  由 von gosling 提交于 9月 17, 2019
```
Add PhysicMsgTimestamp update logic when replicas recovering from the abnormal case.

Closes #1456
```
  523b60cf
16 9月, 2019 3 次提交
- L
  
  docs(operation.md): remove discarded mqadmin command description · 90bbda8f
  由 liuruiyiyang 提交于 9月 16, 2019
  
  90bbda8f
- D
  
  Adapt to the dledger mode · f590bd57
  由 duhenglucky 提交于 9月 16, 2019
  
  f590bd57
- D
  
  Fix the slave abnormal recover slow issue · 44153fd9
  由 duhenglucky 提交于 9月 16, 2019
  
  44153fd9
04 9月, 2019 3 次提交
- K
  
  fix typo · 02b51215
  由 KangZhiDong 提交于 9月 04, 2019
  
  02b51215
- H
  Merge pull request #1444 from yufan022/develop · faef3645
  由 Heng Du 提交于 9月 04, 2019
```
[ISSUES #1439]fix transaction typo
```
  faef3645
- W
  
  fix typo (#1439) · b1cc349f
  由 wangyufan 提交于 9月 04, 2019
  
  b1cc349f
01 9月, 2019 1 次提交
- K
  
  fix typo · acfe8750
  由 KangZhiDong 提交于 9月 01, 2019
  
  acfe8750
28 8月, 2019 3 次提交
- V
  Revert "Remove end of line comment and add override annotation when rewrite method (#1420)" (#1423) · ce4478aa
  由 von gosling 提交于 8月 28, 2019
```
This reverts commit 83de262c.
```
  ce4478aa
- Z
  
  Remove end of line comment and add override annotation when rewrite method (#1420) · 83de262c
  由 zhangzhikai 提交于 8月 28, 2019
  
  83de262c
- K
  [ISSUE 504] Polish 'No route info of this topic' exception (#1415) · 74ffae6d
  由 King 提交于 8月 28, 2019
```
* 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
22 8月, 2019 4 次提交
- H
  Merge pull request #1386 from apache/litePullConsumer · 9edeb4ec
  由 Heng Du 提交于 8月 22, 2019
```
[ISSUE #1388]Add lite pull consumer support for RocketMQ
```
  9edeb4ec
- K
  Add unit test for lite pull consumer (#1410) · 67751d81
  由 King 提交于 8月 22, 2019
```
* Add unit test for lite pull consumer.

* Add synchronized to poll function.
```
  67751d81
- V
  
  Polish the consumer group doc · 2ab9e850
  由 vongosling 提交于 8月 22, 2019
  
  2ab9e850
- V
  
  Deprecated related core pull consumer classes · 2126929a
  由 vongosling 提交于 8月 22, 2019
  
  2126929a
21 8月, 2019 1 次提交

Polish lite pull consumer and fix bug (#1402) · 4a4a464b

由 King 提交于 8月 21, 2019

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

4a4a464b

19 8月, 2019 1 次提交

Polish LitePullConsumer (#1395) · cfca4401

由 King 提交于 8月 19, 2019

* 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

14 8月, 2019 2 次提交

H

Deprecated the DefaulteMQPull consumer (#1387) · ddb07ab1
由 Heng Du 提交于 8月 14, 2019

ddb07ab1

Polish lite pull consumer (#1381) · c6096a14

由 King 提交于 8月 14, 2019

* 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

09 8月, 2019 3 次提交

H

Merge remote-tracking branch 'origin/release-4.5.2' · 2c414fa5
由 huzongtang 提交于 8月 09, 2019

2c414fa5
H

Merge branch 'master' of https://github.com/apache/rocketmq · 5e33f313
由 huzongtang 提交于 8月 09, 2019

5e33f313

Polish lite pull consumer and fix bug (#1373) · 46288abb

由 King 提交于 8月 09, 2019

* 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

02 8月, 2019 1 次提交

Polish lite pull consumer (#1359) · 9c3b26cf

由 King 提交于 8月 02, 2019

* 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

01 8月, 2019 2 次提交
- Z
  
  [maven-release-plugin] prepare for next development iteration · 90ae1167
  由 zongtanghu 提交于 8月 01, 2019
  
  90ae1167
- Z
  
  [maven-release-plugin] prepare release rocketmq-all-4.5.2 · d63678dc
  由 zongtanghu 提交于 8月 01, 2019
  
  d63678dc
31 7月, 2019 6 次提交
- V
  
  Fix the wrong package name · 3fcc038a
  由 vongosling 提交于 7月 31, 2019
  
  3fcc038a
- V
  
  Minor polish · c95a1090
  由 vongosling 提交于 7月 31, 2019
  
  c95a1090
- H
  
  change the MQVersion variable to rocketmq 4.5.2 version; · 0f3b492f
  由 huzongtang 提交于 7月 31, 2019
  
  0f3b492f
- D
  
  Cherry-pick urgent PR from master to develop (#1353) · 4eab2d4c
  由 dinglei 提交于 7月 31, 2019
  
  4eab2d4c
- V
  
  Merge branch 'develop' of github.com:apache/rocketmq into develop · b7b9f1e9
  由 vongosling 提交于 7月 31, 2019
  
  b7b9f1e9
- V
  
  Refactor the protection logic when pulling · 713bb988
  由 vongosling 提交于 7月 31, 2019
  
  713bb988
30 7月, 2019 1 次提交
- R
  
  fix /dev/shm not found on some OSs (#1345) · 7ac5ad37
  由 Rui Liu 提交于 7月 30, 2019
  
  7ac5ad37

super-server / Rocketmq 与 Fork 源项目一致

super-server / Rocketmq
与 Fork 源项目一致