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/08/22 11:59:48 UTC
[rocketmq] branch IPV6 updated (9a52e65 -> c7c9601)
This is an automated email from the ASF dual-hosted git repository.
duhengforever pushed a change to branch IPV6
in repository https://gitbox.apache.org/repos/asf/rocketmq.git.
discard 9a52e65 Revert "[RIP-15]Add Ipv6 support for RocketMQ (#1352)" (#1411)
This update removed existing revisions from the reference, leaving the
reference pointing at a previous point in the repository history.
* -- * -- N refs/heads/IPV6 (c7c9601)
\
O -- O -- O (9a52e65)
Any revisions marked "omit" are not gone; other references still
refer to them. Any revisions marked "discard" are gone forever.
No new revisions were added by this update.
Summary of changes:
CONTRIBUTING.md | 5 +-
README.md | 20 +++
acl/pom.xml | 6 +-
.../org/apache/rocketmq/acl/common/AclUtils.java | 164 ++++++++++++++++++--
.../rocketmq/acl/plain/PlainAccessValidator.java | 2 +-
.../acl/plain/RemoteAddressStrategyFactory.java | 133 ++++++++++++----
.../apache/rocketmq/acl/common/AclUtilsTest.java | 99 ++++++++++--
.../acl/plain/RemoteAddressStrategyTest.java | 147 +++++++++++++++++-
broker/pom.xml | 2 +-
.../broker/processor/PullMessageProcessor.java | 21 ++-
client/pom.xml | 2 +-
.../java/org/apache/rocketmq/client/MQAdmin.java | 2 +-
.../impl/consumer/DefaultMQPullConsumerImpl.java | 38 ++---
.../client/impl/consumer/PullAPIWrapper.java | 2 +-
common/pom.xml | 6 +-
.../java/org/apache/rocketmq/common/MQVersion.java | 2 +-
.../java/org/apache/rocketmq/common/MixAll.java | 6 +-
.../java/org/apache/rocketmq/common/UtilAll.java | 59 ++++++-
.../common/message/MessageClientIDSetter.java | 32 ++--
.../rocketmq/common/message/MessageDecoder.java | 92 +++++++----
.../apache/rocketmq/common/message/MessageExt.java | 22 ++-
.../rocketmq/common/sysflag/MessageSysFlag.java | 3 +
.../rocketmq/common/sysflag/PullSysFlag.java | 2 +-
.../org/apache/rocketmq/common/UtilAllTest.java | 9 ++
.../common/message/MessageClientIDSetterTest.java | 47 ++++++
.../common/message/MessageDecoderTest.java | 169 +++++++++++++++++++++
.../common/protocol/route/TopicRouteDataTest.java | 2 +-
distribution/benchmark/runclass.sh | 34 ++++-
distribution/bin/mqadmin.xml | 43 ------
distribution/bin/mqbroker.xml | 45 ------
distribution/bin/mqnamesrv.xml | 45 ------
distribution/bin/runbroker.sh | 30 +++-
distribution/bin/runserver.sh | 33 +++-
distribution/bin/tools.cmd | 2 +-
distribution/bin/tools.sh | 2 +-
distribution/pom.xml | 2 +-
docs/cn/README.md | 4 +-
docs/cn/best_practice.md | 1 -
docs/cn/concept.md | 7 +-
docs/cn/features.md | 2 +-
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 | 14 +-
remoting/pom.xml | 2 +-
.../rocketmq/remoting/common/RemotingHelper.java | 19 +--
.../rocketmq/remoting/common/RemotingUtil.java | 7 +-
srvutil/pom.xml | 2 +-
store/pom.xml | 2 +-
.../java/org/apache/rocketmq/store/CommitLog.java | 146 +++++++++++++-----
.../apache/rocketmq/store/DefaultMessageStore.java | 10 +-
.../rocketmq/store/config/MessageStoreConfig.java | 2 +-
.../rocketmq/store/dledger/DLedgerCommitLog.java | 67 ++++----
.../org/apache/rocketmq/store/ha/HAService.java | 2 +-
.../apache/rocketmq/store/AppendCallbackTest.java | 97 ++++++++++++
.../apache/rocketmq/store/BatchPutMessageTest.java | 75 +++++++++
.../apache/rocketmq/store/ConsumeQueueTest.java | 29 +++-
.../rocketmq/store/DefaultMessageStoreTest.java | 87 ++++++++---
.../org/apache/rocketmq/store/StoreTestBase.java | 30 +++-
.../store/dledger/DLedgerCommitlogTest.java | 37 ++++-
.../store/dledger/MessageStoreTestBase.java | 3 +-
test/pom.xml | 2 +-
tools/pom.xml | 2 +-
66 files changed, 1564 insertions(+), 431 deletions(-)
create mode 100644 common/src/test/java/org/apache/rocketmq/common/message/MessageClientIDSetterTest.java
delete mode 100644 distribution/bin/mqadmin.xml
delete mode 100644 distribution/bin/mqbroker.xml
delete mode 100644 distribution/bin/mqnamesrv.xml