rocketmq-externals.git
8 days agoModify font size master
vongosling [Fri, 7 Dec 2018 04:47:10 +0000 (12:47 +0800)] 
Modify font size

8 days agoMissing remove sample files
vongosling [Fri, 7 Dec 2018 04:43:23 +0000 (12:43 +0800)] 
Missing remove sample files

8 days agoComment on README file
vongosling [Fri, 7 Dec 2018 04:41:41 +0000 (12:41 +0800)] 
Comment on README file

8 days agoGraduate cpp and spring project, remove it from the incubator repository
vongosling [Fri, 7 Dec 2018 04:40:16 +0000 (12:40 +0800)] 
Graduate cpp and spring project, remove it from the incubator repository

9 days agoSplit the project to serval sub-projects and make each project has clear function...
Kevin Wang [Thu, 6 Dec 2018 06:33:12 +0000 (14:33 +0800)] 
Split the project to serval sub-projects and make each project has clear function (#178)

9 days agoPolish code according to Spring/cloud's review part2 (#175)
Kevin Wang [Thu, 6 Dec 2018 02:26:01 +0000 (10:26 +0800)] 
Polish code according to Spring/cloud's review part2 (#175)

10 days agoUpdate PULL_REQUEST_TEMPLATE.md
von gosling [Wed, 5 Dec 2018 04:56:39 +0000 (12:56 +0800)] 
Update PULL_REQUEST_TEMPLATE.md

11 days agoPolish it
vongosling [Mon, 3 Dec 2018 13:20:06 +0000 (21:20 +0800)] 
Polish it

11 days agoCommit some forgotten polish
vongosling [Mon, 3 Dec 2018 09:51:07 +0000 (17:51 +0800)] 
Commit some forgotten polish

11 days agoRefactor the unit test
vongosling [Mon, 3 Dec 2018 09:47:56 +0000 (17:47 +0800)] 
Refactor the unit test

12 days agoSome polish
vongosling [Mon, 3 Dec 2018 06:32:48 +0000 (14:32 +0800)] 
Some polish

12 days ago[ISSUE-167] Send delay message in RocketMQTemplate directly (#171)
Kevin Wang [Mon, 3 Dec 2018 03:42:09 +0000 (11:42 +0800)] 
[ISSUE-167] Send delay message in RocketMQTemplate directly (#171)

2 weeks agoPolish
vongosling [Fri, 30 Nov 2018 14:27:33 +0000 (22:27 +0800)] 
Polish

2 weeks agoPolish some typo
vongosling [Fri, 30 Nov 2018 11:30:21 +0000 (19:30 +0800)] 
Polish some typo

2 weeks agoCode Refactoring according to spring team's feeback (#169)
Kevin Wang [Fri, 30 Nov 2018 11:06:23 +0000 (19:06 +0800)] 
Code Refactoring according to spring team's feeback (#169)

2 weeks agoRefactor code according to spring-boot team's review (#170)
Kevin Wang [Fri, 30 Nov 2018 11:03:45 +0000 (19:03 +0800)] 
Refactor code according to spring-boot team's review (#170)

* refactor code according to spring-boot team's review

* Update pom.xml

* Update pom.xml

3 weeks ago[ISSUE-160] Fixed README document (#161)
liaotian [Fri, 23 Nov 2018 10:01:11 +0000 (18:01 +0800)] 
[ISSUE-160] Fixed README document  (#161)

* new feature in spring-boot-starter https://github.com/apache/rocketmq-externals/issues/101

* add transactional annotations

* Add @RocketMQTransactionListener

* update doc and format

* remove null name txProducer

* add the unit test for txProducer

* modify README for transactional message

* refactor the code to support more sendMessageInTransaction() methods

* refactor comments and document format

* add spring-boot plugin

* make this file same with forked branch

3 weeks agoFix the bug when getting offset from some of the queues
terry [Fri, 23 Nov 2018 02:31:25 +0000 (10:31 +0800)] 
Fix the bug when getting offset from some of the queues

3 weeks agoFix NPE when getting offset(#153)
SuXingLee [Fri, 23 Nov 2018 02:06:20 +0000 (10:06 +0800)] 
Fix NPE  when getting offset(#153)

rockemq-flink: RocketMQSource will throw a NullPointerException

4 weeks agoCode Refactor, decouple API from native RocketMQ (#139)
liaotian [Mon, 12 Nov 2018 06:00:57 +0000 (14:00 +0800)] 
Code Refactor, decouple API from native RocketMQ (#139)

* new feature in spring-boot-starter https://github.com/apache/rocketmq-externals/issues/101

* add transactional annotations

* Add @RocketMQTransactionListener

* update doc and format

* remove null name txProducer

* add unit test for txProducer

* modify README for transtional message

* refactor the code to support more sendMessageInTransaction() methods

* refactor comments and docment format

* refactor transaction message code in spring-boot-starter, decopule API with native rocketmq

* trival changes according to review comments

5 weeks agoInit the python repo
zander [Thu, 8 Nov 2018 07:59:42 +0000 (15:59 +0800)] 
Init the python repo

5 weeks ago[ISSUE #141]Upgrade redis-replicator to 3.0.1 so that support redis-5.0-GA (#140)
Baoyi Chen [Wed, 7 Nov 2018 15:40:17 +0000 (23:40 +0800)] 
[ISSUE #141]Upgrade redis-replicator to 3.0.1 so that support redis-5.0-GA (#140)

* fix expire bug

* upgrade redis-replicator to 3.0.1

5 weeks agoSetup the maturity model for the community projects
vongosling [Tue, 6 Nov 2018 07:52:25 +0000 (15:52 +0800)] 
Setup the maturity model for the community projects

8 weeks ago[FEATURE REQUEST #488]Export C-style APIs for RocketMQ client (#131)
Shannon [Thu, 18 Oct 2018 09:55:59 +0000 (17:55 +0800)] 
[FEATURE REQUEST #488]Export C-style APIs for RocketMQ client (#131)

* Support C APIs

* modify CmakeList

* General Dynamic Lib

* Remove Chineses Words

* Remove Chineses Words

* Add target for dynamic lib

* Add target for dynamic lib

8 weeks ago[ISSUE #118]enhancement of judgment for message type (#121)
joewee [Mon, 15 Oct 2018 14:19:18 +0000 (22:19 +0800)] 
[ISSUE #118]enhancement of judgment for message type (#121)

8 weeks ago[ISSUE 111] rocketmq-iot-bridge (#112)
XiaoZYang [Mon, 15 Oct 2018 13:51:05 +0000 (21:51 +0800)] 
[ISSUE 111] rocketmq-iot-bridge (#112)

* ADD rocketmq-iot-bridge

* ADD integration test

* FIX license error

* ADD jacoco excludes

* MOD check code coverage in BUNDLE

* FIX typo in comment

* FIX git url in README

8 weeks ago[ISSUE #101] New Feature: support sending transactional message with rocketmq-spring...
liaotian [Mon, 15 Oct 2018 13:45:47 +0000 (21:45 +0800)] 
[ISSUE #101] New Feature: support sending transactional message with rocketmq-spring-boot-starter (#115)

* add transactional annotations

* [ISSUE-101] New Feature: Support sending transactional message with rocketmq-spring-boot-starter

* add more comments and change checkListener annotataion, transName -> txProducerGroup

* adjust some code according to team reviews

* move ROCKET_MQ to ROCKETMQ in variable declaration

* [issues #109] raise an annotation definition exception when attempting to consume message with BROADCASTING + ORDERLY

* Refactor codestyle according to Apache style

* Make the spring-boot sample more readable

2 months ago[ISSUE #104]Add docker images for rocketmq-4.3.0 (#106)
Huan Wei [Wed, 19 Sep 2018 11:06:13 +0000 (19:06 +0800)] 
[ISSUE #104]Add docker images for rocketmq-4.3.0 (#106)

2 months agoFix the cluster switch selection doesn't work in console
jungle [Wed, 19 Sep 2018 10:55:58 +0000 (18:55 +0800)] 
Fix the cluster switch selection doesn't work in console

2 months agofix typo (#120)
Vincent Jia [Wed, 19 Sep 2018 10:44:16 +0000 (18:44 +0800)] 
fix typo (#120)

3 months agoAdded rocketmq-hbase (provides integration with the HBase datastore). It includes...
Sergio Esteves [Mon, 20 Aug 2018 03:27:59 +0000 (04:27 +0100)] 
Added rocketmq-hbase (provides integration with the HBase datastore). It includes the (i) HBase sink, that replicates HBase tables to RocketMQ topics; and (ii) HBase source, that replicates RocketMQ topics to HBase tables. (#97)

4 months agoRefine document (#95)
Eric Fu [Thu, 9 Aug 2018 06:34:36 +0000 (14:34 +0800)] 
Refine document (#95)

4 months ago[ISSUE #71] RocketMQ DataSource for Spark SQL (#72)
Eric Fu [Tue, 7 Aug 2018 02:34:25 +0000 (10:34 +0800)] 
[ISSUE #71] RocketMQ DataSource for Spark SQL (#72)

* RocketMQDataConsumer should share unique RocketMQ consumer client if has same `consumerGroup`

* Adjust schema of RocketMQ data source

* Implement trait `RelationProvider`

* Use max offset as default initial offset

* Add field 'brokerName' to a schema

* Refractor RocketMQConsumer

* Support RocketMQ Sink (not done yet)

* Remove workaround for KAFKA-1894, and remove the dependency on RocketMqUtils

* Clean bunch of redundant code and reorganize configs

* Add test case of batch (aka. relation) source

* Add tests for RocketMQSink

* Make the parameters more user-friendly

* Support release underlying consumer if its group is not used anymore

* fix code style

* Improve test cases

* Support trait `CreatableRelationProvider`

* Add docs

* Some source code was ported from Spark KafkaSource. Add merit for the original author.

4 months ago [ISSUE #75] Add docker support for rocketmq-4.2.0 (#89)
Huan Wei [Tue, 7 Aug 2018 02:26:22 +0000 (10:26 +0800)] 
 [ISSUE #75] Add docker support for rocketmq-4.2.0 (#89)

4 months agoFix rocketmq-redis expire bug
Baoyi Chen [Mon, 30 Jul 2018 02:30:20 +0000 (10:30 +0800)] 
Fix rocketmq-redis expire bug

4 months agoserializer change from fastjson to kryo (#41)
Baoyi Chen [Sat, 28 Jul 2018 03:34:31 +0000 (11:34 +0800)] 
serializer change from fastjson to kryo (#41)

* serializer change from fastjson to kryo
1. fastjson -> kryo.
2. add rocketmq event consumer.
3. fix verbose bug.
4. fix serializable bug.
5. delete unused aof file.
6. fix readme.md.
7. fix doc.
8. fix ByteArrayMap bug.
9. add retrier.
10. add new command evalsha.
11. add new rdb listener to handle huge kv.
12. add new RdbVisitor to convert RDB to dump format.

* change dependency to `redis-replicator-3.0.0-RC2`
remove conflict code with `redis-replicator-3.0.0-RC2`
support redis-5.0

* fix readme

4 months agoRename sentinel module
vongosling [Sat, 28 Jul 2018 02:19:02 +0000 (10:19 +0800)] 
Rename sentinel module

4 months agoSupport the consumer's flow-control using Sentinel (#83)
Eric Zhao [Sat, 28 Jul 2018 02:07:20 +0000 (10:07 +0800)] 
Support the consumer's flow-control using Sentinel   (#83)

6 months agoROCKETMQ-157: Serializer & Deserializer support for RocketMQ (#42)
Xin Wang [Mon, 11 Jun 2018 06:33:50 +0000 (14:33 +0800)] 
ROCKETMQ-157: Serializer & Deserializer support for RocketMQ (#42)

* Serializer&Deserializer support for RocketMQ

6 months agoBugFix: Hold mutex while trying to notify
Li Zhanhui [Sun, 10 Jun 2018 04:30:30 +0000 (12:30 +0800)] 
BugFix: Hold mutex while trying to notify

6 months agoChange the method name "headExits" to "exists". (#65)
Kui LIU [Thu, 7 Jun 2018 07:49:04 +0000 (09:49 +0200)] 
Change the method name "headExits" to "exists". (#65)

6 months agoISSUE-61: Added javadocs for RocketMQ-Flink (#63)
Xin Wang [Thu, 7 Jun 2018 07:40:10 +0000 (15:40 +0800)] 
ISSUE-61: Added javadocs for RocketMQ-Flink (#63)

* ISSUE-61: Added javadocs for RocketMQ-Flink and remove the generated javadoc files

6 months agoMerge pull request #68 from shroman/issue-64
Roman Shtykh [Wed, 6 Jun 2018 03:36:56 +0000 (12:36 +0900)] 
Merge pull request #68 from shroman/issue-64

This closes #64

6 months agoFix encoding
Zhanhui Li [Tue, 5 Jun 2018 06:07:23 +0000 (14:07 +0800)] 
Fix encoding

6 months ago[BugFix]: Fix event_base looping lags behind
Zhanhui Li [Tue, 5 Jun 2018 06:01:43 +0000 (14:01 +0800)] 
[BugFix]: Fix event_base looping lags behind

6 months agoDelete rocketmq-amqp
von gosling [Thu, 17 May 2018 02:14:43 +0000 (10:14 +0800)] 
Delete rocketmq-amqp

6 months agocreate a new file for the GSoC program
von gosling [Thu, 17 May 2018 02:14:18 +0000 (10:14 +0800)] 
create a new file for the GSoC program

7 months agoThis closes #64 68/head
shroman [Fri, 27 Apr 2018 09:42:19 +0000 (18:42 +0900)] 
This closes #64

7 months agoRocketMQ-Spark Improvements (#58)
Xin Wang [Tue, 24 Apr 2018 06:59:42 +0000 (14:59 +0800)] 
RocketMQ-Spark Improvements (#58)

8 months agofix resetoffset parse error, consume duplication and windows rename issue (#47)
vincent wang [Sun, 15 Apr 2018 07:33:12 +0000 (15:33 +0800)] 
fix resetoffset parse error, consume duplication and windows rename issue (#47)

* fix resetoffset parse error which leads to coredump issue

* fix consume duplication issue when consumer or broker are frequent changes

* Fix windows rename file issue

* Update README.md

* format file

* Fix coredump on windows platform when network was broken

8 months agoAdded rocketmq-flink to readme (#54)
Xin Wang [Thu, 12 Apr 2018 07:39:57 +0000 (15:39 +0800)] 
Added rocketmq-flink to readme (#54)

8 months ago[ROCKETMQ-82] RocketMQ-Flink Integration (#45)
Xin Wang [Fri, 23 Mar 2018 13:47:33 +0000 (21:47 +0800)] 
[ROCKETMQ-82] RocketMQ-Flink Integration (#45)

8 months agodocker-compose script has been added for 4.1.0-incubating (#33)
the cat [Thu, 22 Mar 2018 03:10:39 +0000 (22:10 -0500)] 
docker-compose script has been added for 4.1.0-incubating (#33)

8 months agoUpdated to rocketmq 4.2.0 for Flume plugin (#43)
Roman Shtykh [Thu, 22 Mar 2018 03:08:53 +0000 (12:08 +0900)] 
Updated to rocketmq 4.2.0 for Flume plugin (#43)

8 months agoAdd issue and pr template
yukon [Tue, 20 Mar 2018 13:55:01 +0000 (21:55 +0800)] 
Add issue and pr template

10 months ago[ROCKETMQ-352] Import the donation code from Qiwei Wang
vincentWangKB [Tue, 13 Feb 2018 10:04:25 +0000 (18:04 +0800)] 
[ROCKETMQ-352] Import the donation code from Qiwei Wang

10 months ago[ROCKETMQ-352] Remove the code that doesn't pass the IP clearance.
yukon [Tue, 13 Feb 2018 10:01:27 +0000 (18:01 +0800)] 
[ROCKETMQ-352] Remove the code that doesn't pass the IP clearance.

10 months agoUpdate README.md
von gosling [Mon, 5 Feb 2018 08:12:22 +0000 (16:12 +0800)] 
Update README.md

10 months agoRename the dir of spring boot starter
yukon [Fri, 26 Jan 2018 13:37:50 +0000 (21:37 +0800)] 
Rename the dir of spring boot starter

10 months agoMerge branch 'master' of github.com:apache/rocketmq-externals
yukon [Fri, 26 Jan 2018 09:11:45 +0000 (17:11 +0800)] 
Merge branch 'master' of github.com:apache/rocketmq-externals

10 months agoMerge pull request #32 from aqlu/master
yukon [Fri, 26 Jan 2018 09:10:57 +0000 (17:10 +0800)] 
Merge pull request #32 from aqlu/master

[ROCKETMQ-120] Provider a adapter for spring and spring-boot

10 months agoFlume update to 1.8.0. (#44)
Roman Shtykh [Fri, 26 Jan 2018 09:06:33 +0000 (18:06 +0900)] 
Flume update to 1.8.0. (#44)

10 months agoMerge https://github.com/aqlu/rocketmq-externals
yukon [Fri, 19 Jan 2018 14:27:36 +0000 (22:27 +0800)] 
Merge https://github.com/aqlu/rocketmq-externals

11 months agoOptimise pom and clean code. 32/head
angus.aqlu [Tue, 2 Jan 2018 09:12:14 +0000 (17:12 +0800)] 
Optimise pom and clean code.

11 months agosupport windows platform for rocketmq-cpp code
vongosling [Thu, 21 Dec 2017 09:51:05 +0000 (17:51 +0800)] 
support windows platform for rocketmq-cpp code

11 months agoMerge pull request #37 from yangrenyong/bugfix-wrong-offset-storing-in-timer
von gosling [Thu, 21 Dec 2017 07:59:44 +0000 (15:59 +0800)] 
Merge pull request #37 from yangrenyong/bugfix-wrong-offset-storing-in-timer

12 months agoMerge pull request #38 from leonchen83/master
von gosling [Thu, 14 Dec 2017 06:57:23 +0000 (14:57 +0800)] 
Merge pull request #38 from leonchen83/master

Add more redis event to downstream to rocketmq.

12 months ago1. Add more event to downstream to rocketmq .eg(PreFullSync and PostFullSync event... 38/head
leonchen83 [Sat, 9 Dec 2017 09:59:49 +0000 (17:59 +0800)] 
1. Add more event to downstream to rocketmq .eg(PreFullSync and PostFullSync event, AuxField event)
2. Remove global and partial config from replicator.conf.
3. Remove rocketmq instance config.
4. Remove unused pom properties.

12 months agoMerge pull request #29 from leonchen83/master
von gosling [Thu, 7 Dec 2017 02:59:39 +0000 (10:59 +0800)] 
Merge pull request #29 from leonchen83/master

[ROCKETMQ-193] Develop rocketmq-redis-replicator component

12 months agoadd SkipRdbVisitor 29/head
leonchen83 [Wed, 6 Dec 2017 12:13:15 +0000 (20:13 +0800)] 
add SkipRdbVisitor

12 months agoadd a complete demo for `Quick Start`
angus.aqlu [Thu, 16 Nov 2017 12:00:36 +0000 (20:00 +0800)] 
add a complete demo for `Quick Start`

12 months agochanged log level to 'debug' for record cost time
angus.aqlu [Thu, 16 Nov 2017 11:59:02 +0000 (19:59 +0800)] 
changed log level to 'debug' for record cost time

12 months agofix hardcode strings
angus.aqlu [Thu, 16 Nov 2017 09:35:51 +0000 (17:35 +0800)] 
fix hardcode strings

12 months agochanged log level to 'debug' for record cost time
angus.aqlu [Thu, 16 Nov 2017 09:29:56 +0000 (17:29 +0800)] 
changed log level to 'debug' for record cost time

12 months agoremoved redundant information
angus.aqlu [Thu, 16 Nov 2017 09:27:15 +0000 (17:27 +0800)] 
removed redundant information

13 months agoadd README
leonchen83 [Sat, 11 Nov 2017 07:39:01 +0000 (15:39 +0800)] 
add README

13 months agobugfix: fixup wrong offset storing in interval timer 37/head
yangrenyong [Fri, 10 Nov 2017 09:14:04 +0000 (17:14 +0800)] 
bugfix: fixup wrong offset storing in interval timer

13 months agoMerge pull request #36 from yangrenyong/bugfix-messageset
yukon [Wed, 8 Nov 2017 11:59:56 +0000 (05:59 -0600)] 
Merge pull request #36 from yangrenyong/bugfix-messageset

Fix endless data in MessageSet due to the newly created iterator

13 months agoFix PSYNC2 bug.
leonchen83 [Tue, 7 Nov 2017 04:24:15 +0000 (12:24 +0800)] 
Fix PSYNC2 bug.

13 months agofix ByteArrayMap serialize bug
chenby@nextop.cn [Mon, 16 Oct 2017 04:53:42 +0000 (12:53 +0800)] 
fix ByteArrayMap serialize bug

13 months agofix restore command bug
leonchen83 [Sat, 30 Sep 2017 07:54:35 +0000 (15:54 +0800)] 
fix restore command bug

13 months agofix multi thread close bug
leonchen83 [Fri, 29 Sep 2017 09:29:59 +0000 (17:29 +0800)] 
fix multi thread close bug

13 months agojdk9
leon [Fri, 22 Sep 2017 13:30:18 +0000 (21:30 +0800)] 
jdk9

13 months agofix IOException bug
leon [Tue, 19 Sep 2017 14:44:45 +0000 (22:44 +0800)] 
fix IOException bug

13 months agofix redis uri and license
leon [Sat, 16 Sep 2017 03:00:37 +0000 (11:00 +0800)] 
fix redis uri and license

13 months agofix static import
chenby@nextop.cn [Tue, 12 Sep 2017 06:34:14 +0000 (14:34 +0800)] 
fix static import

13 months agotravis ci
chenby@nextop.cn [Thu, 7 Sep 2017 09:36:32 +0000 (17:36 +0800)] 
travis ci

13 months agoAdd two chapters rocketmq-cpp and contribute in README
yukon [Mon, 4 Sep 2017 07:22:02 +0000 (15:22 +0800)] 
Add two chapters rocketmq-cpp and contribute in README

13 months agopolish
vongosling [Mon, 4 Sep 2017 07:05:43 +0000 (15:05 +0800)] 
polish

13 months agopolish
vongosling [Mon, 4 Sep 2017 07:00:26 +0000 (15:00 +0800)] 
polish

13 months agopolish
vongosling [Mon, 4 Sep 2017 06:58:42 +0000 (14:58 +0800)] 
polish

13 months agoPolish
vongosling [Mon, 4 Sep 2017 06:55:53 +0000 (14:55 +0800)] 
Polish

13 months agoPolish
vongosling [Mon, 4 Sep 2017 06:53:21 +0000 (14:53 +0800)] 
Polish

13 months agoPolish cpp module
vongosling [Mon, 4 Sep 2017 06:44:26 +0000 (14:44 +0800)] 
Polish cpp module

13 months agoupload rocketmq-cpp code
qiwei.wqw [Tue, 8 Aug 2017 02:55:19 +0000 (10:55 +0800)] 
upload rocketmq-cpp code

remove unused boost file

update README.md

update readme.md

update readme.md

update readme

add gitkeep to bin

update readme.md

update apache license info

remove static dependency

update readme.md

add jsoncpp and libevent install discription

udpate makefile

update jsoncpp version

unify dependency

update readme

support cmake

instead alog by boost::log

For cmake, remove alog

remove alog comment

[add rocketmq-cpp code #27] add cmake to readme

use rocketmq namespace, update json version to 0.10.6

update cmakelist

update json version to 0.10.6

remove makefile

add default search path for jsoncpp and libevent

Update README.md

fix could not find jsoncpp issue

support build on new g++ version

Remove built .o files

13 months agofixup endless data in MessageSet due to newly created iterator 36/head
yangrenyong [Mon, 6 Nov 2017 08:43:01 +0000 (16:43 +0800)] 
fixup endless data in MessageSet due to newly created iterator

14 months agoremove email recipient 'angus.aqlu@gmail.com'
angus.aqlu [Sat, 14 Oct 2017 01:27:45 +0000 (09:27 +0800)] 
remove email recipient 'angus.aqlu@gmail.com'

14 months agoadd email recipient 'dev@rocketmq.apache.org'
angus.aqlu [Fri, 13 Oct 2017 02:05:57 +0000 (10:05 +0800)] 
add email recipient 'dev@rocketmq.apache.org'

14 months agoremoved all 'Created by'
angus.aqlu [Thu, 12 Oct 2017 01:32:08 +0000 (09:32 +0800)] 
removed all 'Created by'

14 months agoadd a adapter for spring and spring-boot
angus.aqlu [Wed, 11 Oct 2017 08:11:12 +0000 (16:11 +0800)] 
add a adapter for spring and spring-boot