3e5008f288
refactor(build): Remove duplicated logback-core dependency and update some modules to 1.8 compiler lever
2020-07-29 14:12:13 +08:00
fac30c3596
[maven-release-plugin] prepare for next development iteration
2020-06-24 14:05:55 +08:00
9f95a972e1
[maven-release-plugin] prepare release rocketmq-all-4.7.1
2020-06-24 14:05:32 +08:00
3974677f04
[maven-release-plugin] prepare for next development iteration
2020-03-05 19:07:09 +08:00
8ef01a6c63
[maven-release-plugin] prepare release rocketmq-all-4.7.0
2020-03-05 19:06:47 +08:00
dd94362257
[maven-release-plugin] prepare for next development iteration
2020-01-20 22:11:43 +08:00
73bb4b402a
[maven-release-plugin] prepare release rocketmq-all-4.6.1
2020-01-20 22:11:21 +08:00
25c4e1ccb3
Merge branch master into develop
2020-01-20 21:49:07 +08:00
9da19d2e37
optimise benchmark consumer, add consume fail rate option
2020-01-20 20:53:26 +08:00
f1b856a091
feat(pullconsumer) add pull sys flag ( #1658 )
...
feat(lite_pull_consumer) add support for consume from where
test(pull_consumer) add unit test for compute from where
test(PullSysFlag) add lite pull sys flag unit test
feat(pull_consumer) add the verification of ConsumerFromWhere value
2019-12-27 20:11:43 +08:00
34c3454957
Optimise tx benchmark producer ( #1628 )
2019-12-06 10:35:01 +08:00
c3b7d18603
[maven-release-plugin] prepare for next development iteration
2019-11-19 21:00:19 +08:00
d1b4e47c26
[maven-release-plugin] prepare release rocketmq-all-4.6.0
2019-11-19 20:59:56 +08:00
e735fffe74
Merge pull request #1422 from qqeasonchen/rocketmq-dev-rpc
...
[RIP-16]Support request/response pattern
2019-11-14 15:53:00 +08:00
6a6f2e7d59
Merge pull request #1544 from areyouok/4.5.2.fix
...
[ISSUE #1519 ]Optimise performance/stability of transaction message
2019-10-31 09:13:22 +08:00
4fa263f756
code style format
2019-10-16 17:34:56 +08:00
f16fd08c5e
rename REPLY_TO to REPLY_TO_CLIENT
2019-10-16 17:15:11 +08:00
18e44c2bbc
remove reply interface in consumer
2019-10-12 16:53:54 +08:00
df59df3790
Add -n (nameServer) option to benchmark consumer; Enable options(-n/-t/w/-s/-c/-r) to TransactionProducer
2019-10-12 15:58:46 +08:00
0c47fcf716
add recommend client configs in rpc mode
2019-09-26 21:19:48 +08:00
c434ff432c
Merge branch 'develop' of https://github.com/apache/rocketmq into rocketmq-dev-rpc
2019-09-24 20:29:19 +08:00
28936fa12a
add reply interface to consumer
2019-09-23 20:07:41 +08:00
ec1f9266d2
optimize request/response examples
2019-09-18 10:48:15 +08:00
53a6955e5b
[RIP-16]change the way creating reply message
2019-09-12 10:40:21 +08:00
cc0a5e391e
code format
2019-09-11 19:47:47 +08:00
7e221e51e8
add example of request-response model
2019-09-11 19:40:04 +08:00
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
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
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
ddb07ab13c
Deprecated the DefaulteMQPull consumer ( #1387 )
2019-08-14 17:27:31 +08:00
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
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
90ae116798
[maven-release-plugin] prepare for next development iteration
2019-08-01 23:25:38 +08:00
d63678dc50
[maven-release-plugin] prepare release rocketmq-all-4.5.2
2019-08-01 23:25:12 +08:00
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
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
11b686e477
Add lite pull consumer example
2019-07-17 14:33:29 +08:00
5b29b73cc8
Set auto commit ( #914 )
2019-07-11 18:47:40 +08:00
52005aee90
[maven-release-plugin] prepare for next development iteration
2019-05-21 11:19:03 +08:00
639cb5c299
[maven-release-plugin] prepare release rocketmq-all-4.5.1
2019-05-21 11:18:41 +08:00
a73c5f8faa
Merge branch 'develop' into RocketMQ-1120
2019-04-19 15:23:54 +08:00
b80c26292d
[maven-release-plugin] prepare for next development iteration
2019-03-29 13:18:35 +08:00
16293c3306
[maven-release-plugin] prepare release rocketmq-all-4.5.0
2019-03-29 13:18:18 +08:00
3884536c38
[ISSUE #1120 ] Add new feature: support namespace
2019-03-28 21:01:13 +08:00
f3d8d38f9a
[ISSUE #1120 ] Add new feature: support namespace
2019-03-28 20:52:32 +08:00
11f6eddb01
Merge pull request #620 from RongtongJin/polish_filter_example
...
[ISSUE #608 ] Polish filter example
2019-01-24 15:48:54 +08:00
b52738cfbd
[maven-release-plugin] prepare for next development iteration
2019-01-17 19:58:18 +08:00
f61fd5c73f
[maven-release-plugin] prepare release rocketmq-all-4.4.0
2019-01-17 19:57:42 +08:00
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
945257522f
Refine the interface for msg_trace
2018-12-29 14:10:28 +08:00
vongosling