You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by hu...@apache.org on 2019/05/22 09:56:46 UTC
[rocketmq] branch enchanced_acl updated (84d2260 -> 52005ae)
This is an automated email from the ASF dual-hosted git repository.
huzongtang pushed a change to branch enchanced_acl
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from 84d2260 [ISSUE #1164]Fix Consumer Instance can't consume message from slave when cluster is in the high level tps and master has been killed. (#1181)
add e0414c0 [ISSUE #1200] Polish default message trace topic trace (#1201)
add 27e305d [RIP-9]Update Example_Orderly.md (#960)
add db3b4de [RIP-9] Update: the period to a comma - Concept 8 Push Consumer (#1023)
add 5282950 [RIP-9]modify punctuation
add 6bb8cb3 [RIP-9] Update Feature.md in docs/en (#1088)
add b8e882f [RIP-10]Add test cases for IOTinyUtilsTest (#853)
add 2a09907 [RIP-10] Add test cases for QueryConsumeTimeSpanBody.java (#856)
add be69a77 [RIP-10] Add test cases for ServiceThread (#862)
add 1181314 [RIP-10]Add test case for SubscriptionData
add 8a7df13 [RIP-10] Add test cases for ConsumeMessageDirectlyResultTest (#865)
add 6a42489 [RIP-10] Add test cases for CountDownLatch2 (#868)
add 7ef9049 [RIP-10]add test for TopicRouteData (#872)
add 142b3c8 [RIP-10]Add test cases for OffsetMovedEvent (#895)
add 1371ebc [RIP-10]Add test cases for ConfigManager (#917)
add 05d48cf [RIP-10] Add test class for QueryConsumeQueueResponseBody (#918)
add c7bff8a [RIP-10]Add test cases for BrokerStatsData (#934)
add 26878e9 [RIP-10] Add test cases for QueryMsgByUniqueKeySubCommand (#945)
add 8c59640 [RIP-10] modify test case of BrokerConsumeStatusSubCommand (#983)
add 7c50cb7 Update CurrentVersion to release 4.5.1
add 05c0b95 Fix unit test error in ServiceThreadTest
add 08b62fc Add null point check before send message with namespace
add 47d8814 (1) Polish message trace target channel (2) Fix the issue that consume message with namespace trace cannot found
add 3a8a1bc Add comment for AccessChannel class
add 639cb5c [maven-release-plugin] prepare release rocketmq-all-4.5.1
add 52005ae [maven-release-plugin] prepare for next development iteration
No new revisions were added by this update.
Summary of changes:
acl/pom.xml | 2 +-
broker/pom.xml | 2 +-
client/pom.xml | 2 +-
.../org/apache/rocketmq/client/AccessChannel.java | 20 +-
.../org/apache/rocketmq/client/ClientConfig.java | 10 +
.../client/consumer/DefaultMQPushConsumer.java | 2 +-
.../client/producer/DefaultMQProducer.java | 12 +-
.../client/trace/AsyncTraceDispatcher.java | 99 +++++----
.../rocketmq/client/trace/TraceConstants.java | 3 +
.../rocketmq/client/trace/TraceDispatcher.java | 3 +-
.../trace/hook/ConsumeMessageTraceHookImpl.java | 7 +-
.../trace/hook/SendMessageTraceHookImpl.java | 9 +-
common/pom.xml | 2 +-
.../java/org/apache/rocketmq/common/MQVersion.java | 2 +-
.../apache/rocketmq/common/ConfigManagerTest.java | 103 +++++++++
.../rocketmq/common/CountDownLatch2Test.java | 123 +++++++++++
.../apache/rocketmq/common/ServiceThreadTest.java | 138 +++++++++++++
.../protocol/QueryConsumeTimeSpanBodyTest.java | 114 ++++++++++
.../common/protocol/body/BrokerStatsDataTest.java | 71 +++++++
.../body/ConsumeMessageDirectlyResultTest.java | 52 +++++
.../body/QueryConsumeQueueResponseBodyTest.java | 70 +++++++
.../protocol/heartbeat/SubscriptionDataTest.java | 85 ++++++++
.../common/protocol/route/TopicRouteDataTest.java | 111 ++++++++++
.../protocol/topic/OffsetMovedEventTest.java | 68 ++++++
.../rocketmq/common/utils/IOTinyUtilsTest.java | 163 +++++++++++++++
distribution/pom.xml | 2 +-
docs/en/Concept.md | 2 +-
docs/en/Deployment.md | 8 +-
docs/en/Feature.md | 32 +--
example/pom.xml | 6 +-
filter/pom.xml | 2 +-
logappender/pom.xml | 2 +-
logging/pom.xml | 2 +-
namesrv/pom.xml | 2 +-
openmessaging/pom.xml | 2 +-
pom.xml | 2 +-
remoting/pom.xml | 2 +-
srvutil/pom.xml | 2 +-
store/pom.xml | 2 +-
test/pom.xml | 2 +-
tools/pom.xml | 2 +-
.../broker/BrokerConsumeStatsSubCommad.java | 23 ++-
.../message/QueryMsgByUniqueKeySubCommand.java | 23 ++-
.../broker/BrokerConsumeStatsSubCommadTest.java | 12 +-
.../message/QueryMsgByUniqueKeySubCommandTest.java | 230 +++++++++++++++++++++
45 files changed, 1521 insertions(+), 112 deletions(-)
copy filter/src/main/java/org/apache/rocketmq/filter/FilterSpi.java => client/src/main/java/org/apache/rocketmq/client/AccessChannel.java (69%)
create mode 100644 common/src/test/java/org/apache/rocketmq/common/ConfigManagerTest.java
create mode 100644 common/src/test/java/org/apache/rocketmq/common/CountDownLatch2Test.java
create mode 100644 common/src/test/java/org/apache/rocketmq/common/ServiceThreadTest.java
create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/QueryConsumeTimeSpanBodyTest.java
create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/body/BrokerStatsDataTest.java
create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/body/ConsumeMessageDirectlyResultTest.java
create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/body/QueryConsumeQueueResponseBodyTest.java
create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/heartbeat/SubscriptionDataTest.java
create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/route/TopicRouteDataTest.java
create mode 100644 common/src/test/java/org/apache/rocketmq/common/protocol/topic/OffsetMovedEventTest.java
create mode 100644 common/src/test/java/org/apache/rocketmq/common/utils/IOTinyUtilsTest.java
create mode 100644 tools/src/test/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommandTest.java