This is an automated email from the ASF dual-hosted git repository.
jinrongtong pushed a change to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git
from 2930994a3 [ISSUE #4584] Add new persist method to update consume
offset to remote server.
add bbbb96e12 Revert "Support build with Bazel (#4865)"
No new revisions were added by this update.
Summary of changes:
.bazelrc | 73 ------------
.bazelversion | 1 -
.github/workflows/bazel.yml | 22 ----
.github/workflows/{maven.yaml => build.yaml} | 2 +-
.gitignore | 4 -
.licenserc.yaml | 1 -
BUILD.bazel | 46 --------
WORKSPACE | 128 ---------------------
acl/BUILD.bazel | 73 ------------
.../acl/plain/RemoteAddressStrategyFactory.java | 6 +-
bazel/BUILD.bazel | 16 ---
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 +-
.../processor/ReplyMessageProcessorTest.java | 2 -
.../schedule/ScheduleMessageServiceTest.java | 4 +-
client/BUILD.bazel | 62 ----------
.../impl/producer/DefaultMQProducerImpl.java | 2 +-
.../consumer/DefaultLitePullConsumerTest.java | 12 --
.../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 | 3 -
.../rocketmq/common/utils/IOTinyUtilsTest.java | 8 +-
container/BUILD.bazel | 82 -------------
controller/BUILD.bazel | 73 ------------
.../controller/impl/DLedgerControllerTest.java | 5 -
filter/BUILD.bazel | 59 ----------
logging/BUILD.bazel | 24 ----
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 186014 -> 0 bytes
.../apache/rocketmq/store/ha/DefaultHAService.java | 9 +-
.../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 | 21 ++--
.../apache/rocketmq/store/MultiDispatchTest.java | 6 +-
.../org/apache/rocketmq/store/StoreTestBase.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 +-
.../{BaseBroadcast.java => BaseBroadCastIT.java} | 12 +-
...iveIT.java => BroadCastNormalMsgNotRecvIT.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 +-
105 files changed, 243 insertions(+), 1880 deletions(-)
delete mode 100644 .bazelrc
delete mode 100644 .bazelversion
delete mode 100644 .github/workflows/bazel.yml
rename .github/workflows/{maven.yaml => build.yaml} (94%)
delete mode 100644 BUILD.bazel
delete mode 100644 WORKSPACE
delete mode 100644 acl/BUILD.bazel
delete mode 100644 bazel/BUILD.bazel
delete mode 100644 bazel/GenTestRules.bzl
delete mode 100644 broker/BUILD.bazel
delete mode 100644 client/BUILD.bazel
delete mode 100644 common/BUILD.bazel
delete mode 100644 container/BUILD.bazel
delete mode 100644 controller/BUILD.bazel
delete mode 100644 filter/BUILD.bazel
delete mode 100644 logging/BUILD.bazel
delete mode 100644 namesrv/BUILD.bazel
delete mode 100644 proxy/BUILD.bazel
delete mode 100644 remoting/BUILD.bazel
delete mode 100644 srvutil/BUILD.bazel
rename srvutil/src/{test/java =>
main/test}/org/apache/rocketmq/srvutil/FileWatchServiceTest.java (100%)
delete mode 100644 store/BUILD.bazel
delete mode 100644 store/libs/dledger-0.2.8-SNAPSHOT.jar
delete mode 100644 test/BUILD.bazel
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/{BaseBroadcast.java
=> BaseBroadCastIT.java} (87%)
rename
test/src/test/java/org/apache/rocketmq/test/client/consumer/broadcast/normal/{BroadcastNormalMsgNotReceiveIT.java
=> BroadCastNormalMsgNotRecvIT.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%)
delete mode 100644 tools/BUILD.bazel
