opensource/rocketmq
3
0
Fork 0
mirror of https://github.com/apache/rocketmq.git synced 2026-10-31 02:57:35 +08:00
Code Issues Packages Projects Releases Wiki Activity
1,237 Commits 75 Branches 40 Tags
c6cbab9994cea96370830578a4643e2a6972bebb
Commit Graph
84 Commits
Author SHA1 Message Date
qqeasonchen 4fa263f756 code style format 2019-10-16 17:34:56 +08:00
qqeasonchen f16fd08c5e rename REPLY_TO to REPLY_TO_CLIENT 2019-10-16 17:15:11 +08:00
qqeasonchen 18e44c2bbc remove reply interface in consumer 2019-10-12 16:53:54 +08:00
qqeasonchen 0c47fcf716 add recommend client configs in rpc mode 2019-09-26 21:19:48 +08:00
qqeasonchen c434ff432c Merge branch 'develop' of https://github.com/apache/rocketmq into rocketmq-dev-rpc 2019-09-24 20:29:19 +08:00
qqeasonchen 28936fa12a add reply interface to consumer 2019-09-23 20:07:41 +08:00
qqeasonchen ec1f9266d2 optimize request/response examples 2019-09-18 10:48:15 +08:00
qqeasonchen 53a6955e5b [RIP-16]change the way creating reply message 2019-09-12 10:40:21 +08:00
qqeasonchen cc0a5e391e code format 2019-09-11 19:47:47 +08:00
qqeasonchen 7e221e51e8 add example of request-response model 2019-09-11 19:40:04 +08:00
Heng Du 9edeb4ecd8 Merge pull request #1386 from apache/litePullConsumer 
[ISSUE #1388]Add lite pull consumer support for RocketMQ
 2019-08-22 21:07:18 +08:00
King 4a4a464b25 Polish lite pull consumer and fix bug (#1402) 
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
 2019-08-21 09:23:59 +08:00
King cfca4401d5 Polish LitePullConsumer (#1395) 
* 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
 2019-08-19 14:57:16 +08:00
Heng Du ddb07ab13c Deprecated the DefaulteMQPull consumer (#1387) 2019-08-14 17:27:31 +08:00
King 46288abb33 Polish lite pull consumer and fix bug (#1373) 
* 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
 2019-08-09 11:26:53 +08:00
King 9c3b26cfd3 Polish lite pull consumer (#1359) 
* 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
 2019-08-02 10:34:06 +08:00
zongtanghu 90ae116798 [maven-release-plugin] prepare for next development iteration 2019-08-01 23:25:38 +08:00
zongtanghu d63678dc50 [maven-release-plugin] prepare release rocketmq-all-4.5.2 2019-08-01 23:25:12 +08:00
King 83098eb604 Polish lite pull consumer (#1349) 
* 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
 2019-07-30 10:59:13 +08:00
King 62ca947a45 Polish LitePullConsumer (#1332) 
* 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
 2019-07-19 11:19:07 +08:00
duhenglucky 11b686e477 Add lite pull consumer example 2019-07-17 14:33:29 +08:00
ymwneu 5b29b73cc8 Set auto commit (#914) 2019-07-11 18:47:40 +08:00
ShannonDing 52005aee90 [maven-release-plugin] prepare for next development iteration 2019-05-21 11:19:03 +08:00
ShannonDing 639cb5c299 [maven-release-plugin] prepare release rocketmq-all-4.5.1 2019-05-21 11:18:41 +08:00
Heng Du a73c5f8faa Merge branch 'develop' into RocketMQ-1120 2019-04-19 15:23:54 +08:00
wlliqipeng b80c26292d [maven-release-plugin] prepare for next development iteration 2019-03-29 13:18:35 +08:00
wlliqipeng 16293c3306 [maven-release-plugin] prepare release rocketmq-all-4.5.0 2019-03-29 13:18:18 +08:00
lollipop 3884536c38 [ISSUE #1120] Add new feature: support namespace 2019-03-28 21:01:13 +08:00
lollipop f3d8d38f9a [ISSUE #1120] Add new feature: support namespace 2019-03-28 20:52:32 +08:00
Heng Du 11f6eddb01 Merge pull request #620 from RongtongJin/polish_filter_example 
[ISSUE #608] Polish filter example
 2019-01-24 15:48:54 +08:00
duhenglucky b52738cfbd [maven-release-plugin] prepare for next development iteration 2019-01-17 19:58:18 +08:00
duhenglucky f61fd5c73f [maven-release-plugin] prepare release rocketmq-all-4.4.0 2019-01-17 19:57:42 +08:00
Hu Zongtang 691b712167 [ISSUE#662]capitalizing the first letter in comments and removing the unless comments for acl and msg trace feature codes. (#669) 
* [ISSUE#662]capitalizing the first letter in comments and removing the  unless comments for acl and msg trace feature codes.

* [ISSUE#662]polish the acl feature codes.
 2019-01-07 19:03:54 +08:00
dongeforever 945257522f Refine the interface for msg_trace 2018-12-29 14:10:28 +08:00
dongeforever b8cb82f47c Rename tracktrace to trace, and polish the package hierarchy 2018-12-28 14:21:18 +08:00
dongeforever 4250af6e56 Merge branch 'feature_acl' into msg_track 2018-12-26 21:23:26 +08:00
huzongtang 62fbeeb0f1 [ISSUE#403]adjust AclClient codes for rocketmq's acl feature and Ignore a unit test. 2018-12-26 14:22:51 +08:00
Jin Rongtong e20437657a polish filter example 2018-12-22 11:18:42 +08:00
huzongtang cde6f40441 [ISSUE #525] Support the message track,these committed codes have supported trace_topic name value Configurable by users. 2018-12-11 16:03:53 +08:00
huzongtang 47556d6a36 I have already fix my code as suggestion.Please help to review them.[ISSUE #525]. 2018-11-28 10:50:55 +08:00
huzongtang e04db85e66 I have finished developing the new feature for the message track #525 initially. 2018-11-14 00:16:40 +08:00
dongeforever 2a93a9bfd3 Polish acl 2018-11-09 16:51:05 +08:00
laohu 11d3df66ec add acl use example. AclClient.java 2018-11-08 15:21:42 +08:00
laohu 94403714ee add acl use example. AclClient.java 2018-11-08 13:03:03 +08:00
duhengforever 6d946faf42 Polish async send message sample 2018-10-31 17:39:13 +08:00
hujie 62e65d633d ad unit test 2018-10-08 21:36:51 +08:00
hujie 9e0021db04 acl-plug rudimentary model 2018-10-01 22:20:05 +08:00
duhengforever f6696b12c8 Compatible with the original transactional message API 2018-08-10 16:31:58 +08:00
duhengforever 9db2acdb85 Rename variable name 2018-08-09 10:00:37 +08:00
duhengforever 61a0fcba5e Reslove compatibility issues and keep consistent with the old API 2018-08-08 21:58:01 +08:00