This is an automated email from the ASF dual-hosted git repository.
dinglei pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
from 6bea1eb Merge branch 'develop'
add f3d8d38 [ISSUE #1120] Add new feature: support namespace
add 3884536 [ISSUE #1120] Add new feature: support namespace
add 2e222b6 [ISSUE #1120] Add some test cases and remove redundant code.
add b80c262 [maven-release-plugin] prepare for next development iteration
add 29438a1 [ISSUE #1078]fix User can't use mqadmin command normally if
they don't copy the tool.yml file to related fold and AclEnable flag is closed.
(#1079)
add 8780048 Change the release package style to rocketmq-{version}
add 6afe0f8 Deprecate admin interface exposed in producer/consumer
add 264f270 Change vipChannelEnabled property default value to false
add f5c9aaa Deprecate sendMessageBack for change it's visibilty in the
future
add 0c2afc9 Remove unused import in DefaultMQProducer
add a73c5f8 Merge branch 'develop' into RocketMQ-1120
add 54fcbe9 Resolve same method definition brought by merge
add 9e05be6 Merge pull request #1122 from lollipopjin/RocketMQ-1120
add b11bbd9 [ISSUE #1147]Add name server domain host support (#1175)
add 929c76c [ISSUE #1147]Broker will report Exception if open the
aclEnable and enableDLegerCommitLog flag at the same time. (#1149)
add b3384d2 [issue#1164]Consumer Instance can't consume message from
slave when the TPS of cluster is in the high level and master has been killed.
add 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
new 8e44ca1 Release Apache RocketMQ 4.5.1
The 1 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:
acl/pom.xml | 2 +-
.../org/apache/rocketmq/acl/common/AclUtils.java | 41 +++-
.../rocketmq/acl/plain/PlainAccessValidator.java | 9 +-
.../apache/rocketmq/acl/common/AclUtilsTest.java | 31 ++-
.../acl/plain/PlainAccessValidatorTest.java | 15 +-
...ain_acl_null.yml => plain_acl_format_error.yml} | 8 +
...plain_acl_null.yml => plain_acl_incomplete.yml} | 6 +-
broker/pom.xml | 2 +-
.../broker/mqtrace/ConsumeMessageContext.java | 9 +
.../broker/mqtrace/SendMessageContext.java | 11 +-
.../processor/AbstractSendMessageProcessor.java | 21 +-
.../broker/processor/SendMessageProcessor.java | 11 +-
client/pom.xml | 2 +-
.../org/apache/rocketmq/client/AccessChannel.java | 20 +-
.../org/apache/rocketmq/client/ClientConfig.java | 82 +++++++-
.../client/consumer/DefaultMQPullConsumer.java | 151 ++++++++++----
.../client/consumer/DefaultMQPushConsumer.java | 224 +++++++++++++++-----
.../client/hook/ConsumeMessageContext.java | 9 +
.../rocketmq/client/hook/SendMessageContext.java | 9 +
.../client/impl/ClientRemotingProcessor.java | 11 +-
.../apache/rocketmq/client/impl/MQAdminImpl.java | 21 +-
.../rocketmq/client/impl/MQClientAPIImpl.java | 15 +-
.../ConsumeMessageConcurrentlyService.java | 20 +-
.../consumer/ConsumeMessageOrderlyService.java | 15 ++
.../impl/consumer/DefaultMQPullConsumerImpl.java | 45 +++-
.../impl/consumer/DefaultMQPushConsumerImpl.java | 31 ++-
.../client/impl/factory/MQClientInstance.java | 27 +++
.../impl/producer/DefaultMQProducerImpl.java | 36 +++-
.../client/producer/DefaultMQProducer.java | 183 ++++++++++++----
.../client/producer/TransactionMQProducer.java | 14 +-
.../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 | 6 +-
.../java/org/apache/rocketmq/common/MQVersion.java | 2 +-
.../java/org/apache/rocketmq/common/MixAll.java | 1 +
.../apache/rocketmq/common/message/Message.java | 4 +
.../rocketmq/common/message/MessageConst.java | 2 +
.../rocketmq/common/protocol/NamespaceUtil.java | 172 +++++++++++++++
.../common/utils/NameServerAddressUtils.java | 40 ++++
.../apache/rocketmq/common/ConfigManagerTest.java | 103 +++++++++
.../rocketmq/common/CountDownLatch2Test.java | 123 +++++++++++
.../apache/rocketmq/common/ServiceThreadTest.java | 138 +++++++++++++
.../common/protocol/NamespaceUtilTest.java | 91 ++++++++
.../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/conf/plain_acl.yml | 2 +
distribution/conf/tools.yml | 2 +-
distribution/pom.xml | 6 +-
distribution/release-client.xml | 17 +-
distribution/release.xml | 2 +-
docs/cn/acl/user_guide.md | 10 +-
docs/en/Concept.md | 2 +-
docs/en/Deployment.md | 8 +-
docs/en/Feature.md | 32 +--
example/pom.xml | 6 +-
.../ProducerWithNamespace.java} | 31 ++-
.../PullConsumerWithNamespace.java} | 38 ++--
.../namespace/PushConsumerWithNamespace.java | 37 ++++
filter/pom.xml | 2 +-
logappender/pom.xml | 2 +-
logging/pom.xml | 2 +-
namesrv/pom.xml | 2 +-
openmessaging/pom.xml | 2 +-
pom.xml | 4 +-
remoting/pom.xml | 2 +-
srvutil/pom.xml | 2 +-
store/pom.xml | 2 +-
.../apache/rocketmq/store/DefaultMessageStore.java | 12 +-
test/pom.xml | 2 +-
tools/pom.xml | 2 +-
.../rocketmq/tools/command/MQAdminStartup.java | 32 +--
.../broker/BrokerConsumeStatsSubCommad.java | 23 ++-
.../message/QueryMsgByUniqueKeySubCommand.java | 23 ++-
.../broker/BrokerConsumeStatsSubCommadTest.java | 12 +-
.../message/QueryMsgByUniqueKeySubCommandTest.java | 230 +++++++++++++++++++++
84 files changed, 2795 insertions(+), 372 deletions(-)
copy acl/src/test/resources/conf/{plain_acl_null.yml =>
plain_acl_format_error.yml} (84%)
copy acl/src/test/resources/conf/{plain_acl_null.yml =>
plain_acl_incomplete.yml} (85%)
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/main/java/org/apache/rocketmq/common/protocol/NamespaceUtil.java
create mode 100644
common/src/main/java/org/apache/rocketmq/common/utils/NameServerAddressUtils.java
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/NamespaceUtilTest.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
copy
example/src/main/java/org/apache/rocketmq/example/{filter/TagFilterProducer.java
=> namespace/ProducerWithNamespace.java} (62%)
copy
example/src/main/java/org/apache/rocketmq/example/{simple/PullConsumer.java =>
namespace/PullConsumerWithNamespace.java} (68%)
create mode 100644
example/src/main/java/org/apache/rocketmq/example/namespace/PushConsumerWithNamespace.java
create mode 100644
tools/src/test/java/org/apache/rocketmq/tools/command/message/QueryMsgByUniqueKeySubCommandTest.java
