提交 · 2ab9e850fa69de02b62c9da7d64a109f8b7d74a9 · 十年彩虹 / Rocketmq

22 8月, 2019 2 次提交
- 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 1 次提交

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

30 7月, 2019 1 次提交

Polish lite pull consumer (#1349) · 83098eb6

由 King 提交于 7月 30, 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

83098eb6

19 7月, 2019 1 次提交

Polish LitePullConsumer (#1332) · 62ca947a

由 King 提交于 7月 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

62ca947a

17 7月, 2019 1 次提交
- D
  
  Add lite pull consumer example · 11b686e4
  由 duhenglucky 提交于 7月 17, 2019
  
  11b686e4
21 6月, 2019 1 次提交
- D
  
  Add pull task logic · af04557a
  由 duhenglucky 提交于 6月 21, 2019
  
  af04557a
20 6月, 2019 1 次提交
- D
  
  Add pull schedual service · 2aae40f9
  由 duhenglucky 提交于 6月 20, 2019
  
  2aae40f9
19 6月, 2019 1 次提交

程

[ISSUE #598] Enhance transaction by putting messages that exceed max check... · d66243c0

由程向往提交于 6月 19, 2019

[ISSUE #598] Enhance transaction by putting messages that exceed max check times to system topic (#633)

* add logic of putting message that exceeds max-check-times to system topic TRANS_CHECK_MAXTIME_TOPIC

* add test case:testResolveDiscardMsg

* add @after logic to test case

* comment brokerController.shutdown and use mock

* add logic of resuming half message check

* add test case:resumeCheckHalfMessage

* delete commented codes

d66243c0

18 6月, 2019 1 次提交
- D
  
  Delay plant log appender in client loggger (#1266) · ea88c4b7
  由 dinglei 提交于 6月 18, 2019
  
  ea88c4b7
17 6月, 2019 2 次提交
- K
  
  fix typo (#1260) · bf2a7e51
  由 kexianjun 提交于 6月 17, 2019
  
  bf2a7e51
- H
  [ISSUE #1241]optimize the codes for issue that Suggestion about the third part... · ac7b16da
  由 Hu Zongtang 提交于 6月 17, 2019
```
[ISSUE #1241]optimize the codes for issue that Suggestion about the third part dependency of the RocketMQ client. (#1264)
```
  ac7b16da
16 6月, 2019 1 次提交
- H
  Merge pull request #1257 from apache/enchanced_acl · a5d34dd4
  由 Heng Du 提交于 6月 16, 2019
```
[ISSUE #1156]Add new mqadmin API for ACL configuration
```
  a5d34dd4
14 6月, 2019 11 次提交

H

[ISSUE #1156]fix too many files with unapproved license issues; · d1db4a1a
由 huzongtang 提交于 6月 14, 2019

d1db4a1a
H

[ISSUE #1156]fix failure test cases for acl mqadmin command; · 3adbca97
由 huzongtang 提交于 6月 14, 2019

3adbca97
H

Merge remote-tracking branch 'origin/develop' into enchanced_acl · 18601ec8
由 huzongtang 提交于 6月 14, 2019

18601ec8

[ISSUE #1156]new mqadmin API for ACL configuration (#1217) · a2165d80

由 Hu Zongtang 提交于 6月 14, 2019

* [issue#1164]return the codes to original reput method part.

* [issue#1164]fix issue that Consumer Instance can't consume message from slave when cluster is in the high level tps and master has been killed.

* [issue#1164]if the broker is a master node,then modify reputFromOffset correctly.

* [issue#1164]add some coding comments.

* [ISSUE#1156]new mqadmin API for ACL configuration.Add dataVersion and write data to acl yaml config file in the acl module.

* [ISSUE#1156]add unit test cases for new acl mqadmin API command which adding dataversion part.

* [ISSUE#1156]implement update,delete and query Acl config version in new acl mqadmin API command.

* [ISSUE#1156]polish and optimize the implementation for new acl mqadmin API command.

* [ISSUE#1156]fix the issues that topicPerms and groupPerms can't be updated and there is NPE when querying acl config version.

* [ISSUE#1156]fix small issue that specify wrong plainAccessConfig attribute,the correct one is AccessKey.

* [ISSUE#1156]add updateGlobalWhiteAddr subcommand codes for mqadmin acl command.

* [ISSUE#1156]adjust some codes for cluster acl config version list in the mqadmin acl commands.

* [ISSUE#1156]add acl mqadmin command part in the acl user_guide docs.

* [ISSUE#1156]polish and optimize some part of acl mqadmin command codes.

* [ISSUE#1156]fix code comments issue that the first letter needs to be capitalized and adjust the contents of acl user_guide.

a2165d80

周
modify exception declaration · a7e77d28
由周浪提交于 5月 23, 2019
```
modify "TimeDelayLevel in not supported for batching"
```
a7e77d28
C
Update best_practice.md · 38a4e4ba
由 chenxubiao 提交于 6月 05, 2019
```
config name wrong
```
38a4e4ba
V

Update NOTICE · 21b64c6e
由 von gosling 提交于 3月 04, 2019

21b64c6e
V

Update copyright year · 21588c29
由 von gosling 提交于 3月 04, 2019

21588c29
[RIP-9] Commit docs Example_OpenMessaging.md (#797) · 9c60f2f9
由易先生3729 提交于 2月 21, 2019
```
[RIP-9] Commit docs Example_OpenMessaging.md 
```
9c60f2f9
V

Update README.md · e1fa99ae
由 von gosling 提交于 1月 10, 2019

e1fa99ae
V

Update issue_template.md · 918a82a3
由 von gosling 提交于 1月 10, 2019

918a82a3

13 6月, 2019 2 次提交
- Z
  
  [FIX] Travis-CI Java 8 building environments. (#1256) · cd473fed
  由 ziheng 提交于 6月 13, 2019
  
  cd473fed
- Z
  
  fix typo (#1232) · e9bc3661
  由 Zhang Chao 提交于 6月 13, 2019
  
  e9bc3661
12 6月, 2019 2 次提交
- P
  
  FIX: HmacSHA1 not found if JAVA_HOME set to JRE (#1140) · c409c358
  由 Preston 提交于 6月 12, 2019
  
  c409c358
- H
  
  Add namespace support for transaction message (#1254) · 6c5fc49d
  由 Heng Du 提交于 6月 12, 2019
  
  6c5fc49d
28 5月, 2019 7 次提交
- H
  Merge pull request #1235 from githublaohu/travis · 5e6c21f7
  由 Heng Du 提交于 5月 28, 2019
```
Repair travis CI execute failed issue
```
  5e6c21f7
- L
  
  trusty · efefbaab
  由 laohu 提交于 5月 28, 2019
  
  efefbaab
- L
  
  test jdk9 · c2f75035
  由 laohu 提交于 5月 28, 2019
  
  c2f75035
- L
  
  changge travis · c9d6a087
  由 laohu 提交于 5月 28, 2019
  
  c9d6a087
- L
  
  changge travis · 03786670
  由 laohu 提交于 5月 28, 2019
  
  03786670
- L
  
  1 · 477a3917
  由 laohu 提交于 5月 28, 2019
  
  477a3917
- L
  
  change travis.yml · 8126cfac
  由 laohu 提交于 5月 28, 2019
  
  8126cfac

十年彩虹 / Rocketmq 与 Fork 源项目一致

十年彩虹 / Rocketmq
与 Fork 源项目一致