This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 10d291846 [ISSUE #4832] Remove innerProducer and innerConsumer in
EscapeBridge (#4834)
add 3da7ea9c1 [Infra Improvement] Build And Run Unit Tests in Parallel
(#4878)
No new revisions were added by this update.
Summary of changes:
.bazelrc | 73 ++++++++++++
.bazelversion | 1 +
.github/workflows/bazel.yml | 22 ++++
.github/workflows/{build.yaml => maven.yaml} | 4 +-
.gitignore | 5 +
.licenserc.yaml | 1 +
BUILD.bazel | 46 ++++++++
WORKSPACE | 128 ++++++++++++++++++++
acl/BUILD.bazel | 72 ++++++++++++
.../org/apache/rocketmq/acl/common/AclUtils.java | 90 +++++---------
.../acl/plain/RemoteAddressStrategyFactory.java | 6 +-
.../apache/rocketmq/acl/common/AclUtilsTest.java | 129 ++++++++-------------
.../configuration.properties => bazel/BUILD.bazel | 4 +-
bazel/GenTestRules.bzl | 109 +++++++++++++++++
broker/BUILD.bazel | 82 +++++++++++++
.../apache/rocketmq/broker/BrokerController.java | 15 ++-
.../processor/AbstractSendMessageProcessor.java | 11 +-
.../rocketmq/broker/BrokerControllerTest.java | 37 ++++--
.../broker/filter/MessageStoreWithFilterTest.java | 2 +-
.../broker/offset/ConsumerOffsetManagerTest.java | 4 +-
.../schedule/ScheduleMessageServiceTest.java | 4 +-
client/BUILD.bazel | 65 +++++++++++
.../impl/producer/DefaultMQProducerImpl.java | 2 +-
.../consumer/DefaultLitePullConsumerTest.java | 6 +
.../client/impl/factory/MQClientInstanceTest.java | 2 +-
.../DefaultMQLitePullConsumerWithTraceTest.java | 6 +
common/BUILD.bazel | 60 ++++++++++
.../java/org/apache/rocketmq/common/MixAll.java | 2 +-
.../org/apache/rocketmq/common/MixAllTest.java | 2 +-
.../common/message/MessageClientIDSetterTest.java | 4 +-
.../common/message/MessageDecoderTest.java | 1 +
.../rocketmq/common/utils/IOTinyUtilsTest.java | 8 +-
container/BUILD.bazel | 82 +++++++++++++
controller/BUILD.bazel | 76 ++++++++++++
.../controller/impl/DLedgerControllerTest.java | 5 +-
filter/BUILD.bazel | 59 ++++++++++
.../broker-trace.properties => logging/BUILD.bazel | 15 +--
namesrv/BUILD.bazel | 76 ++++++++++++
.../apache/rocketmq/namesrv/NamesrvController.java | 5 +
.../apache/rocketmq/namesrv/NamesrvStartup.java | 4 +-
.../rocketmq/namesrv/NameServerInstanceTest.java | 9 ++
proxy/BUILD.bazel | 97 ++++++++++++++++
.../rocketmq/proxy/config/Configuration.java | 11 ++
.../grpc/v2/common/GrpcClientSettingsManager.java | 3 +-
.../proxy/config/InitConfigAndLoggerTest.java | 22 +++-
.../grpc/v2/GrpcMessagingApplicationTest.java | 15 ++-
remoting/BUILD.bazel | 50 ++++++++
.../remoting/netty/NettyRemotingClient.java | 3 +-
.../remoting/netty/NettyRemotingServer.java | 25 ++--
.../rocketmq/remoting/netty/NettyServerConfig.java | 2 +-
.../rocketmq/remoting/RemotingServerTest.java | 9 +-
.../rocketmq/remoting/SubRemotingServerTest.java | 8 +-
.../java/org/apache/rocketmq/remoting/TlsTest.java | 46 ++++++--
srvutil/BUILD.bazel | 59 ++++++++++
.../rocketmq/srvutil/FileWatchServiceTest.java | 0
store/BUILD.bazel | 80 +++++++++++++
store/libs/dledger-0.2.8-SNAPSHOT.jar | Bin 0 -> 186014 bytes
.../rocketmq/store/config/MessageStoreConfig.java | 4 +
.../apache/rocketmq/store/ha/DefaultHAService.java | 28 +++--
.../store/ha/autoswitch/AutoSwitchHAService.java | 7 +-
.../apache/rocketmq/store/AppendCallbackTest.java | 6 +-
.../apache/rocketmq/store/BatchPutMessageTest.java | 8 +-
.../apache/rocketmq/store/ConsumeQueueTest.java | 4 +-
.../store/DefaultMessageStoreCleanFilesTest.java | 2 +-
.../store/DefaultMessageStoreShutDownTest.java | 5 +-
.../rocketmq/store/DefaultMessageStoreTest.java | 66 +++++++----
.../java/org/apache/rocketmq/store/HATest.java | 22 ++--
.../apache/rocketmq/store/MultiDispatchTest.java | 6 +-
.../org/apache/rocketmq/store/StoreTestBase.java | 2 +-
.../rocketmq/store/timer/StoreTestUtils.java | 2 +-
.../store/timer/TimerMessageStoreTest.java | 2 -
test/BUILD.bazel | 107 +++++++++++++++++
.../apache/rocketmq/test/schema/SchemaTools.java | 2 +-
.../org/apache/rocketmq/test/util/RandomUtil.java | 2 +-
.../rocketmq/test/base/IntegrationTestBase.java | 15 +--
.../base/dledger/DLedgerProduceAndConsumeIT.java | 6 +-
.../{BaseBroadCastIT.java => BaseBroadcast.java} | 12 +-
...IT.java => BroadcastNormalMsgNotReceiveIT.java} | 4 +-
...hIT.java => BroadcastNormalMsgRecvCrashIT.java} | 4 +-
...ilIT.java => BroadcastNormalMsgRecvFailIT.java} | 4 +-
...ava => BroadcastNormalMsgRecvStartLaterIT.java} | 4 +-
...a => BroadcastNormalMsgTwoDiffGroupRecvIT.java} | 4 +-
.../normal/NormalMsgTwoSameGroupConsumerIT.java | 4 +-
...sgBroadCastIT.java => OrderMsgBroadcastIT.java} | 6 +-
...erIT.java => BroadcastTwoConsumerFilterIT.java} | 6 +-
....java => BroadcastTwoConsumerSubDiffTagIT.java} | 6 +-
...agIT.java => BroadcastTwoConsumerSubTagIT.java} | 6 +-
.../apache/rocketmq/test/grpc/v2/GrpcBaseIT.java | 6 +-
tools/BUILD.bazel | 68 +++++++++++
.../rocketmq/tools/command/MQAdminStartup.java | 3 +-
.../acl/ClusterAclConfigVersionListSubCommand.java | 2 +-
.../connection/ProducerConnectionSubCommand.java | 4 +
.../consumer/ConsumerProgressSubCommand.java | 4 +
.../command/consumer/ConsumerStatusSubCommand.java | 4 +
.../consumer/GetConsumerConfigSubCommand.java | 5 +
.../message/QueryMsgTraceByIdSubCommand.java | 3 +
.../command/namesrv/UpdateKvConfigCommand.java | 4 +
.../command/offset/GetConsumerStatusCommand.java | 5 +
.../command/offset/ResetOffsetByTimeCommand.java | 4 +
.../tools/admin/DefaultMQAdminExtTest.java | 2 +-
.../broker/CleanUnusedTopicCommandTest.java | 6 +-
.../ProducerConnectionSubCommandTest.java | 10 +-
.../consumer/ConsumerProgressSubCommandTest.java | 11 +-
.../consumer/ConsumerStatusSubCommandTest.java | 11 +-
.../consumer/GetConsumerConfigSubCommandTest.java | 18 ++-
.../message/QueryMsgTraceByIdSubCommandTest.java | 15 +--
.../command/namesrv/UpdateKvConfigCommandTest.java | 11 +-
.../offset/GetConsumerStatusCommandTest.java | 17 +--
.../offset/ResetOffsetByTimeCommandTest.java | 11 +-
.../tools/command/server/ServerResponseMocker.java | 10 +-
110 files changed, 1938 insertions(+), 416 deletions(-)
create mode 100644 .bazelrc
create mode 100644 .bazelversion
create mode 100644 .github/workflows/bazel.yml
rename .github/workflows/{build.yaml => maven.yaml} (89%)
create mode 100644 BUILD.bazel
create mode 100644 WORKSPACE
create mode 100644 acl/BUILD.bazel
copy
client/src/test/resources/org/powermock/extensions/configuration.properties =>
bazel/BUILD.bazel (94%)
create mode 100644 bazel/GenTestRules.bzl
create mode 100644 broker/BUILD.bazel
create mode 100644 client/BUILD.bazel
create mode 100644 common/BUILD.bazel
create mode 100644 container/BUILD.bazel
create mode 100644 controller/BUILD.bazel
create mode 100644 filter/BUILD.bazel
copy distribution/conf/2m-noslave/broker-trace.properties =>
logging/BUILD.bazel (80%)
create mode 100644 namesrv/BUILD.bazel
create mode 100644 proxy/BUILD.bazel
create mode 100644 remoting/BUILD.bazel
create mode 100644 srvutil/BUILD.bazel
rename srvutil/src/{main/test =>
test/java}/org/apache/rocketmq/srvutil/FileWatchServiceTest.java (100%)
create mode 100644 store/BUILD.bazel
create mode 100644 store/libs/dledger-0.2.8-SNAPSHOT.jar
create mode 100644 test/BUILD.bazel
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/{BaseBroadCastIT.java
=> BaseBroadcast.java} (87%)
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/{BroadCastNormalMsgNotRecvIT.java
=> BroadcastNormalMsgNotReceiveIT.java} (97%)
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/{BroadCastNormalMsgRecvCrashIT.java
=> BroadcastNormalMsgRecvCrashIT.java} (97%)
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/{BroadCastNormalMsgRecvFailIT.java
=> BroadcastNormalMsgRecvFailIT.java} (97%)
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/{BroadCastNormalMsgRecvStartLaterIT.java
=> BroadcastNormalMsgRecvStartLaterIT.java} (97%)
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/{BroadCastNormalMsgTwoDiffGroupRecvIT.java
=> BroadcastNormalMsgTwoDiffGroupRecvIT.java} (97%)
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/order/{OrderMsgBroadCastIT.java
=> OrderMsgBroadcastIT.java} (97%)
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/{BroadCastTwoConsumerFilterIT.java
=> BroadcastTwoConsumerFilterIT.java} (95%)
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/{BroadCastTwoConsumerSubDiffTagIT.java
=> BroadcastTwoConsumerSubDiffTagIT.java} (95%)
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/tag/{BroadCastTwoConsumerSubTagIT.java
=> BroadcastTwoConsumerSubTagIT.java} (95%)
create mode 100644 tools/BUILD.bazel
