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
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
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
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
duheng
b054a9d4c1
[ISSUE #292 ] Add support of transactional message feature ( #358 )
2018-07-15 10:51:41 +08:00
shutian.lzh
2169e3c075
Make code compatible to OMS 0.3.0
2018-04-24 11:38:10 +08:00
lindzh
46f91479d9
[ROCKETMQ-359] Replace slf4j api used in RocketMQ with InternalLogger ( #221 )
2018-03-07 14:29:09 +08:00
lindzh
1bbd4cd62b
[ROCKETMQ-291] Fix System.out.printf throws UnknownFormatConversionException
...
Author: lindzh <linsony0@163.com >
Closes #168 from lindzh/fix_print.
2017-10-12 14:56:00 +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
dongeforever
f45a1bcd2b
[ROCKETMQ-219] Add batch example, closes apache/incubator-rocketmq#112
2017-06-08 11:20:40 +08:00
dongeforever
703ac00bd2
[ROCKETMQ-220] Add IT test for Filter By SQL 92, closes
...
apache/incubator-rocketmq#114
2017-06-08 11:20:15 +08:00
dongeforever
e57f9ac433
Merge remote-tracking branch 'wip/ROCKETMQ-206' into develop
2017-05-27 12:39:25 +08:00
yukon
aced0de7d8
[ROCKETMQ-206] Catch the IOException when call the file2String method.
2017-05-27 11:34:44 +08:00
lindzh
99ce40a723
[ROCKETMQ-189] Misleading tip on consumeTimestamp and wrong consumeTimestamp exception message closes apache/incubator-rocketmq#97
2017-05-26 15:28:28 +08:00
yukon
1d966b50c2
[ROCKETMQ-186] Implement the OpenMessaging specification 0.1.0-alpha version
2017-05-24 16:50:51 +08:00
vsair
58f1574b28
[ROCKETMQ-121]Support message filtering based on SQL92 closes apache/incubator-rocketmq#82
2017-04-21 18:17:58 +08:00
dongeforever
bd008546b8
[ROCKETMQ-83] Fix quick start, annotate setNamesrvAddr, closes apache/incubator-rocketmq#54
2017-02-10 16:47:33 +08:00
Zhanhui Li
e9a87ea93e
Add javadoc to quick start examples.
2017-01-22 16:20:21 +08:00
shroman
1562bd0d11
[ROCKETMQ-30] Fixed method signature for Message Filter example and class loading from resources, closes apache/incubator-rocketmq#27
2017-01-09 16:28:10 +08:00
dongeforever
167cce0348
ROCKETMQ-18 Clean code closes apache/incubator-rocketmq#21
2016-12-29 15:25:05 +08:00
yukon
f9d90201d0
ROCKETMQ-18 Polish copyright and remove unnecessary code.
2016-12-29 11:53:38 +08:00
yukon
853b167bda
ROCKETMQ-18 Fix the conflicts between code and check style.
2016-12-28 16:11:32 +08:00
Heng Du