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 2021/05/26 15:50:57 UTC

[rocketmq] branch develop updated (cca4d92 -> 620d02f)

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

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


    from cca4d92  Merge pull request #2948 from lizhimins/fix-offset
     new fbb35d3  [ISSUE #2898] Resolve rocketmq-example project failed during checkstyle execution
     new e47f655  Merge remote-tracking branch 'upstream/develop' into develop
     new b81e90f  Merge remote-tracking branch 'upstream/develop' into develop
     new db05f81  Merge remote-tracking branch 'upstream/develop' into develop
     new f244ee3  [ISSUE #2556] LitePullConsumer support message trace.
     new 2dc75d3  The messageTrace related configurations is set as a property
     new 620d02f  Merge pull request #2930 from zhangjidi2016/litePullConsumer_support_msgTrace

The 1616 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/pom.xml                                     |   4 +
 .../client/consumer/DefaultLitePullConsumer.java   |  65 +++++
 .../impl/consumer/DefaultLitePullConsumerImpl.java |  46 +++
 .../rocketmq/client/trace/TraceDataEncoder.java    |  15 +-
 .../apache/rocketmq/client/trace/TraceView.java    |  12 +-
 .../trace/hook/ConsumeMessageTraceHookImpl.java    |  16 +-
 .../trace/hook/SendMessageTraceHookImpl.java       |   1 -
 ...=> DefaultMQLitePullConsumerWithTraceTest.java} | 314 ++++++++++-----------
 .../client/trace/TraceDataEncoderTest.java         |   5 +-
 .../rocketmq/client/trace/TraceViewTest.java       |  40 +--
 .../message/QueryMsgTraceByIdSubCommand.java       |  54 ++--
 11 files changed, 329 insertions(+), 243 deletions(-)
 copy client/src/test/java/org/apache/rocketmq/client/trace/{DefaultMQConsumerWithTraceTest.java => DefaultMQLitePullConsumerWithTraceTest.java} (50%)