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

Posted to commits@rocketmq.apache.org by do...@apache.org on 2018/12/19 11:54:12 UTC

[rocketmq] 01/01: Merge pull request #600 from zongtanghu/msg_track

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

dongeforever pushed a commit to branch msg_track
in repository https://gitbox.apache.org/repos/asf/rocketmq.git

commit d572ffab7c344140124d981b439dcbec2e16dc4e
Merge: c50ada6 d480c81
Author: Zhendong Liu <zh...@yeah.net>
AuthorDate: Wed Dec 19 19:54:03 2018 +0800

    Merge pull request #600 from zongtanghu/msg_track
    
    [ISSUE #525] Support the message track,add the function which supports trace topic name value configurable by users.

 .../rocketmq/broker/topic/TopicConfigManager.java   |  2 +-
 .../client/consumer/DefaultMQPushConsumer.java      | 13 ++++++++++---
 .../rocketmq/client/producer/DefaultMQProducer.java | 16 ++++++++++++----
 .../trace/core/common/TrackTraceConstants.java      |  4 +---
 .../core/dispatch/impl/AsyncArrayDispatcher.java    | 21 ++++++++++++++-------
 .../trace/core/hook/SendMessageTrackHookImpl.java   |  7 +++----
 .../trace/DefaultMQConsumerWithTraceTest.java       | 10 ++++++----
 .../trace/DefaultMQProducerWithTraceTest.java       | 13 ++++++++++---
 .../org/apache/rocketmq/common/BrokerConfig.java    | 10 ++++++++++
 .../apache/rocketmq/common/BrokerConfigTest.java    | 20 ++++++++++++++++++++
 .../example/tracemessage/TraceProducer.java         |  2 +-
 .../example/tracemessage/TracePushConsumer.java     |  3 ++-
 .../logappender/common/ProducerInstance.java        |  2 +-
 .../rocketmq/logappender/AbstractTestCase.java      |  2 +-
 .../rocketmq/test/client/rmq/RMQNormalConsumer.java |  2 +-
 .../rocketmq/test/factory/ProducerFactory.java      |  2 +-
 .../command/message/QueryMsgByIdSubCommand.java     |  2 +-
 .../rocketmq/tools/monitor/MonitorService.java      |  2 +-
 18 files changed, 96 insertions(+), 37 deletions(-)