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/01/31 02:59:57 UTC

[rocketmq] branch snode updated (b3dfa1c -> 8f51777)

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 b3dfa1c  Merge pull request #733 from xiangwangcheng/snode
     new 245146b  Support link to snode
     new 318c606  Update Consumer.java
     new 6021e46  Update Producer.java
     new 38d71d9  Update AsyncProducer.java
     new 8f51777  Merge pull request #738 from ShannonDing/snode

The 640 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/exception/MQSnodeException.java         |  17 +-
 .../rocketmq/client/impl/MQClientAPIImpl.java      |  29 +++-
 .../impl/consumer/DefaultMQPushConsumerImpl.java   |   5 +-
 .../client/impl/consumer/PullAPIWrapper.java       |  17 +-
 .../client/impl/factory/MQClientInstance.java      | 184 ++++++++++++++++++---
 .../impl/producer/DefaultMQProducerImpl.java       |  30 ++--
 .../rocketmq/example/quickstart/Producer.java      |   3 +-
 7 files changed, 224 insertions(+), 61 deletions(-)
 copy remoting/src/main/java/org/apache/rocketmq/remoting/transport/mqtt/DisconnectChannelEvent.java => client/src/main/java/org/apache/rocketmq/client/exception/MQSnodeException.java (72%)