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/02/19 07:41:25 UTC

[rocketmq] branch snode updated (6909795 -> 26f8ae8)

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

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


    from 6909795  Remove snode address in MessageExt clas
     new 82b18d5  Add RealPush rebalance as default
     new 673fead  Merge branch 'snode' of github.com:apache/rocketmq into snode
     new d49da7b  Open real push model for push consumer
     new b8edd0b  Submit Push Message to consumeservice
     new 26f8ae8  Merge pull request #813 from ShannonDing/snode

The 886 revisions listed above as "new" are entirely new to this
repository and will be described in separate emails.  The revisions
listed as "add" were already present in the repository and have only
been added to this reference.


Summary of changes:
 .../client/consumer/DefaultMQPushConsumer.java     |  72 +++++++++------
 .../client/impl/ClientRemotingProcessor.java       |  23 ++++-
 .../rocketmq/client/impl/MQClientAPIImpl.java      |   2 +
 .../impl/consumer/DefaultMQPushConsumerImpl.java   | 100 ++++++++++++++++++++-
 .../client/impl/consumer/RebalancePushImpl.java    |   1 +
 .../impl/consumer/RebalanceRealPushImpl.java       |  19 ++--
 .../client/impl/factory/MQClientInstance.java      |  14 +++
 7 files changed, 189 insertions(+), 42 deletions(-)
 copy filter/src/main/java/org/apache/rocketmq/filter/expression/EmptyEvaluationContext.java => client/src/main/java/org/apache/rocketmq/client/impl/consumer/RebalanceRealPushImpl.java (68%)