opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-08-30 18:10:44 +08:00
Code Issues Packages Projects Releases Wiki Activity
9,189 Commits 72 Branches 40 Tags
develop
Commit Graph

730 Commits

Author SHA1 Message Date
dongeforever d2cafcf6bf Fix locktime and group 2018-11-20 15:59:51 +08:00
dongeforever b3ba266862 Fix os pache cache busy problem 2018-11-20 15:59:51 +08:00
dongeforever cc3f9f3b3a Fix check style 2018-11-20 15:59:51 +08:00
dongeforever 29fb333911 fix 2018-11-20 15:59:51 +08:00
dongeforever dbc5987b4a Fix tests 2018-11-20 15:59:51 +08:00
dongeforever 1a2fe9f81b Test the committed pos for dleger 2018-11-20 15:59:51 +08:00
dongeforever 456691bf1e Add IT tests for dleger commitlog 2018-11-20 15:59:51 +08:00
dongeforever 5f73002850 Add role change handler for broker controller 2018-11-20 15:59:51 +08:00
dongeforever 515bc3538d Add dleger commitlog with tests 2018-11-20 15:59:51 +08:00
liuchunlong 3c524c2003 fix comment 2018-11-16 17:12:41 +08:00
duheng edf97032e4 Merge pull request #501 from suiyuzeng/issue_recover 
[ISSUE #467] fix Message missed after recovering from abnormal shutdown
 2018-11-01 19:38:11 +08:00
Zhendong Liu d3d4225a07 fix 2018-11-01 19:10:55 +08:00
Zhendong Liu bd026fb6b7 remove isDamanged 2018-11-01 19:10:05 +08:00
suiyuzeng f9841cbab6 code style 2018-10-19 16:53:55 +08:00
suiyuzeng af352d510b code style 2018-10-19 16:49:25 +08:00
suiyuzeng da73a1d142 log recover issue 2018-10-19 15:43:52 +08:00
jungle 4a22c0c0c1 [ISSUE #411] Fixed ClassCastException when get the instance of the store (#423) 
* Fixed issue #411

* fix cast in getAllDelayOffset

* Update AdminBrokerProcessor.java
 2018-10-19 14:18:56 +08:00
dongeforever 2b692c912d Merge branch 'develop' 2018-08-01 14:41:07 +08:00
huangyiming 439796f7c4 [ISSUE #375] Replace the message_magic_code and blank_magic_code value 2018-07-23 19:58:10 +08:00
duheng b054a9d4c1 [ISSUE #292] Add support of transactional message feature (#358) 2018-07-15 10:51:41 +08:00
Jason918 0f76489882 [ROCKETMQ-290] Fix memory leak in WaitNotifyObject#waitingThreadTable (#178) 2018-07-14 11:01:42 +08:00
Wenwei Hu 6eed5f1cdc [ROCKETMQ-296] fix DefaultMessageStoreTest bug: wait more time for consume queue build (#165) 2018-07-14 10:57:29 +08:00
what-a-good-jungle 94f3b5a41b [ISSUE #353]Optimzation For Unit Test (#356) 2018-07-05 20:01:49 +08:00
vongosling 9932819eed Fix the problem of the capitalization in class name 2018-06-12 17:39:32 +08:00
vongosling 4d76016455 Polish parts slow UT 2018-06-12 17:26:59 +08:00
Li Zhanhui 8422e74fa5 Shutdown all thread pools when broker quits 2018-06-01 10:05:37 +08:00
王松松 97322eaf8e Fix Concurrent issue of StoreStatsService 2018-05-28 17:29:21 +08:00
Li Zhanhui 130c85c3cd Revert "Fix Concurrent issue of StoreStatsService" 
This reverts commit fdc6e87cbe.
 2018-05-28 17:10:33 +08:00
Li Zhanhui 61009b7c28 Revert "Fix licence" 
This reverts commit bc84984e17.
 2018-05-28 17:10:16 +08:00
王松松 bc84984e17 Fix licence 2018-05-28 17:01:18 +08:00
王松松 fdc6e87cbe Fix Concurrent issue of StoreStatsService 2018-05-28 17:01:18 +08:00
lindzh 46f91479d9 [ROCKETMQ-359] Replace slf4j api used in RocketMQ with InternalLogger (#221) 2018-03-07 14:29:09 +08:00
yukon 9151a32b2e [ROCKETMQ-332] Verify the offset by firstMappedFile and lastMappedFile 2018-01-17 21:27:22 +08:00
yukon 04e97de8a7 [ROCKETMQ-332] Fix concurrent bug in MappedFileQueue#findMappedFileByOffset, which may cause message loss 2018-01-16 21:33:12 +08:00
Zhendong Liu c67413749d [ROCKETMQ-320]Message loss when shutdown with dispatch behind (#197) 2017-12-13 19:40:42 +08:00
Zhendong Liu 390f73582b [ROCKETMQ-321] Fix deleting files in the middle (#198) 2017-12-13 19:35:21 +08:00
yukon f18dc03809 [ROCKETMQ-270] Move flush position forward to first MappedFile whose start offset is non-zero. 2017-11-02 11:38:38 +08:00
Zhendong Liu bbd27c1503 Merge pull request #179 from fucongchan/fixed_typo 
Fixed typo.
 2017-10-18 10:22:25 +08:00
fucongchan 4365373842 Fixed typo 2017-10-18 01:28:59 +08:00
zander dc4f36867c Merge pull request #108 from aCoder2013/feature/correct-spelling-mistake 
[ROCKETMQ-207]Correct spelling mistake in RouteInfoManager.java
 2017-10-11 10:31:26 +08:00
王松松 eabe47fd60 Fixed:code style 2017-10-09 14:01:14 +08:00
王松松 d20cdd884d Fixed : code style 2017-10-09 14:00:14 +08:00
wangkai 27a678de3c [ROCKETMQ-273] return an expression when a function has no write operations. 
Author: wangkai <8738115@qq.com>

Closes #150 from kevin-better/develop.
 2017-09-20 12:19:15 +08:00
傅冲 368e7c86a0 [ROCKETMQ-265] fix consume queue's data maybe repeat bug 
Author: 傅冲 <yubao.fyb@alibaba-inc.com>
Author: fuyou001 <fuyou001@gmail.com>

Closes #146 from fuyou001/ROCKETMQ-265.
 2017-09-05 20:28:23 +08:00
傅冲 6a97d2884f [ROCKETMQ-281] Add check policy for preventing repeat start mq 
Author: 傅冲 <yubao.fyb@alibaba-inc.com>
Author: fuyou001 <fuyou001@gmail.com>

Closes #158 from fuyou001/ROCKETMQ-281.
 2017-09-05 11:30:11 +08:00
vsair 254d432496 [ROCKETMQ-284] ExpressionMessageFilter will pass some message. 
Author: vsair <liuxuedee@gmail.com>

Closes #160 from vsair/ROCKETMQ-284.
 2017-08-30 00:14:27 +08:00
lindzh 76464ba657 ROCKETMQ-264 Fix ut's time-consuming problems closes apache/incubator-rocketmq#145 2017-08-28 18:00:18 +08:00
yukon 332df78e2b [ROCKETMQ-261] Use write lock when destroy IndexService 2017-08-11 22:17:32 +08:00
yukon 97aa813eb8 Reformat code globally second time 2017-08-11 20:50:22 +08:00
yukon 7f96008c8b Remove unused class GetRouteInfoResponseHeader and meaningless comments 2017-08-11 20:28:13 +08:00