You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by du...@apache.org on 2019/08/19 06:57:21 UTC

[rocketmq] branch litePullConsumer updated (ddb07ab -> cfca440)

This is an automated email from the ASF dual-hosted git repository.

duhengforever pushed a change to branch litePullConsumer
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.


    from ddb07ab  Deprecated the DefaulteMQPull consumer (#1387)
     add cfca440  Polish LitePullConsumer (#1395)

No new revisions were added by this update.

Summary of changes:
 .../client/consumer/DefaultLitePullConsumer.java   | 197 ++++++++++++----
 .../rocketmq/client/consumer/LitePullConsumer.java | 100 +++++++-
 .../client/impl/consumer/AssignedMessageQueue.java |  94 ++++----
 .../impl/consumer/DefaultLitePullConsumerImpl.java |  74 +++---
 .../consumer/DefaultLitePullConsumerTest.java      | 251 +++++++++++++--------
 ...llConsumer.java => LitePullConsumerAssign.java} |  30 +--
 ...onsumer.java => LitePullConsumerSubscribe.java} |  33 ++-
 7 files changed, 525 insertions(+), 254 deletions(-)
 copy example/src/main/java/org/apache/rocketmq/example/simple/{LitePullConsumer.java => LitePullConsumerAssign.java} (70%)
 rename example/src/main/java/org/apache/rocketmq/example/simple/{LitePullConsumer.java => LitePullConsumerSubscribe.java} (59%)