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/21 01:24:06 UTC

[rocketmq] branch litePullConsumer updated (cfca440 -> 4a4a464)

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 cfca440  Polish LitePullConsumer (#1395)
     add 4a4a464  Polish lite pull consumer and fix bug (#1402)

No new revisions were added by this update.

Summary of changes:
 .../org/apache/rocketmq/client/Validators.java     |   9 +-
 .../client/consumer/DefaultLitePullConsumer.java   | 129 ++--------
 .../consumer/store/RemoteBrokerOffsetStore.java    |  41 ++--
 .../client/impl/consumer/AssignedMessageQueue.java |  20 +-
 .../impl/consumer/DefaultLitePullConsumerImpl.java | 266 ++++++++++-----------
 .../client/impl/factory/MQClientInstance.java      |   4 -
 .../consumer/DefaultLitePullConsumerTest.java      |  22 +-
 .../example/simple/LitePullConsumerSubscribe.java  |   4 +-
 8 files changed, 191 insertions(+), 304 deletions(-)