- - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.schema files (114): test/src/test/resources/schema/api/client.producer.DefaultMQProducer.schema test/src/test/resources/schema/api/tools.admin.DefaultMQAdminExt.schema test/src/test/resources/schema/api/client.consumer.AllocateMessageQueueStrategy.schema test/src/test/resources/schema/api/common.message.MessageQueue.schema test/src/test/resources/schema/api/client.hook.SendMessageContext.schema test/src/test/resources/schema/api/client.hook.EndTransactionContext.schema test/src/test/resources/schema/api/client.consumer.PullResult.schema test/src/test/resources/schema/api/client.hook.FilterMessageHook.schema test/src/test/resources/schema/api/client.producer.MessageQueueSelector.schema test/src/test/resources/schema/api/client.consumer.listener.MessageListenerOrderly.schema test/src/test/resources/schema/api/common.message.Message.schema test/src/test/resources/schema/api/client.hook.ConsumeMessageHook.schema test/src/test/resources/schema/api/client.consumer.PullStatus.schema test/src/test/resources/schema/api/client.producer.SendStatus.schema test/src/test/resources/schema/api/client.consumer.listener.ConsumeOrderlyContext.schema test/src/test/resources/schema/api/client.hook.SendMessageHook.schema test/src/test/resources/schema/api/client.hook.FilterMessageContext.schema test/src/test/resources/schema/api/client.producer.SendResult.schema test/src/test/resources/schema/api/remoting.RPCHook.schema test/src/test/resources/schema/api/client.consumer.listener.MessageListener.schema test/src/test/resources/schema/api/client.consumer.listener.ConsumeOrderlyStatus.schema test/src/test/resources/schema/api/client.consumer.DefaultMQPullConsumer.schema test/src/test/resources/schema/api/common.message.MessageExt.schema test/src/test/resources/schema/api/client.consumer.PullCallback.schema test/src/test/resources/schema/api/client.producer.SendCallback.schema test/src/test/resources/schema/api/client.consumer.listener.ConsumeConcurrentlyContext.schema test/src/test/resources/schema/api/client.consumer.listener.MessageListenerConcurrently.schema test/src/test/resources/schema/api/client.hook.CheckForbiddenHook.schema test/src/test/resources/schema/api/client.hook.EndTransactionHook.schema test/src/test/resources/schema/api/client.consumer.DefaultMQPushConsumer.schema test/src/test/resources/schema/api/client.hook.ConsumeMessageContext.schema test/src/test/resources/schema/api/client.consumer.listener.ConsumeConcurrentlyStatus.schema test/src/test/resources/schema/api/client.consumer.DefaultLitePullConsumer.schema test/src/test/resources/schema/protocol/common.protocol.header.GetConsumerRunningInfoRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.QueryDataVersionRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.DeleteTopicFromNamesrvRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.SendMessageResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.RegisterOrderTopicRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.SendMessageRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.QueryConsumeQueueRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.SearchOffsetResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.CheckTransactionStateRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.ViewBrokerStatsDataRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetMinOffsetRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.WipeWritePermOfBrokerResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetBrokerAclConfigResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.DeleteAccessConfigRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetMaxOffsetResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.QueryTopicConsumeByWhoRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.filtersrv.RegisterFilterServerResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.ConsumeMessageDirectlyResultRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetMaxOffsetRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.QueryConsumerOffsetRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetConsumerListByGroupResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetEarliestMsgStoretimeResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.DeleteSubscriptionGroupRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.RegisterBrokerRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.DeleteTopicRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.EndTransactionRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.RequestCode.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.GetKVListByNamespaceRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.UpdateConsumerOffsetRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetConsumeStatsInBrokerHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetConsumeStatsRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.CreateTopicRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.PullMessageResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.EndTransactionResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.ViewMessageResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.RegisterBrokerResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.filtersrv.RegisterMessageFilterClassRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.UnregisterClientRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.QueryMessageRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.CloneGroupOffsetRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.UnRegisterBrokerRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetConsumerListByGroupRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.PullMessageRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.AddWritePermOfBrokerResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.filtersrv.RegisterFilterServerRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.AddWritePermOfBrokerRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetConsumerStatusRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.QueryMessageResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.QueryConsumeTimeSpanRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.ConsumerSendMsgBackRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.PutKVConfigRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.ReplyMessageRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.UpdateGlobalWhiteAddrsConfigRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetConsumerConnectionListRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetProducerConnectionListRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetTopicsByClusterRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetAllTopicConfigResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.DeleteKVConfigRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.SendMessageRequestHeaderV2.schema test/src/test/resources/schema/protocol/common.protocol.header.QueryConsumerOffsetResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.ResumeCheckHalfMessageRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.NotifyConsumerIdsChangedRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.SearchOffsetRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.GetKVConfigResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetMinOffsetResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.CheckTransactionStateResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetBrokerConfigResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetEarliestMsgStoretimeRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.CreateAccessConfigRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.ResetOffsetRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.ViewMessageRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.GetRouteInfoRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.QueryCorrectionOffsetHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetTopicStatsInfoRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.GetKVConfigRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetBrokerClusterAclConfigResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.UpdateConsumerOffsetResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.WipeWritePermOfBrokerRequestHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.UnregisterClientResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.namesrv.QueryDataVersionResponseHeader.schema test/src/test/resources/schema/protocol/common.protocol.header.GetAllProducerInfoRequestHeader.schema - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.png files (63): docs/cn/image/rocketmq_design_13.png docs/cn/image/rocketmq_design_1.png docs/cn/image/rocketmq_design_4.png docs/cn/image/rocketmq_architecture_2.png docs/cn/image/producer_send_request.png docs/cn/image/rocketmq_architecture_3.png docs/cn/image/consumer_reply.png docs/cn/image/rocketmq_design_7.png docs/cn/image/rocketmq_design_6.png docs/cn/image/rocketmq_design_9.png docs/cn/image/rocketmq_architecture_1.png docs/cn/image/controller/quick-start/syncstateset.png docs/cn/image/controller/quick-start/controller.png docs/cn/image/controller/quick-start/changemaster.png docs/cn/image/controller/quick-start/epoch.png docs/cn/image/controller/controller_design_1.png docs/cn/image/controller/controller_design_3.png docs/cn/image/controller/persistent_unique_broker_id/fail_apply_broker_id.png docs/cn/image/controller/persistent_unique_broker_id/normal_restart.png docs/cn/image/controller/persistent_unique_broker_id/register_state_transfer.png docs/cn/image/controller/persistent_unique_broker_id/register_process.png docs/cn/image/controller/persistent_unique_broker_id/fail_create_metadata_file_and_delete_temp.png docs/cn/image/controller/persistent_unique_broker_id/fail_create_temp_metadata_file.png docs/cn/image/controller/controller_design_4.png docs/cn/image/controller/controller_design_6.png docs/cn/image/controller/controller_design_5.png docs/cn/image/controller/controller_design_2.png docs/cn/image/Idea_config_broker.png docs/cn/image/rocketmq_design_3.png docs/cn/image/rocketmq_design_5.png docs/cn/image/rocketmq_design_11.png docs/cn/image/Idea_config_nameserver.png docs/cn/image/rocketmq_design_2.png docs/cn/image/rocketmq_design_10.png docs/cn/image/rocketmq_design_8.png docs/cn/image/rocketmq_design_12.png docs/cn/image/LMQ_1.png docs/en/image/rocketmq_architecture_2.png docs/en/image/rocketmq_architecture_3.png docs/en/image/rocketmq_architecture_1.png docs/en/image/controller/quick-start/syncstateset.png docs/en/image/controller/quick-start/controller.png docs/en/image/controller/quick-start/changemaster.png docs/en/image/controller/quick-start/epoch.png docs/en/image/controller/controller_design_1.png docs/en/image/controller/controller_design_3.png docs/en/image/controller/persistent_unique_broker_id/fail_apply_broker_id.png docs/en/image/controller/persistent_unique_broker_id/normal_restart.png docs/en/image/controller/persistent_unique_broker_id/register_state_transfer.png docs/en/image/controller/persistent_unique_broker_id/register_process.png docs/en/image/controller/persistent_unique_broker_id/fail_create_metadata_file_and_delete_temp.png docs/en/image/controller/persistent_unique_broker_id/fail_create_temp_metadata_file.png docs/en/image/controller/controller_design_4.png docs/en/image/controller/controller_design_6.png docs/en/image/controller/controller_design_5.png docs/en/image/controller/controller_design_2.png docs/en/images/rocketmq_storage_flush.png docs/en/images/rocketmq_storage_arch.png docs/en/images/rocketmq_design_message_query.png docs/en/images/rocketmq_design_7.png docs/en/images/rocketmq_proxy_local_mode.png docs/en/images/rocketmq_proxy_cluster_mode.png tieredstore/tiered_storage_arch.png - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.conf files (23): distribution/conf/controller/cluster-3n-namesrv-plugin/namesrv-n2.conf distribution/conf/controller/cluster-3n-namesrv-plugin/namesrv-n0.conf distribution/conf/controller/cluster-3n-namesrv-plugin/namesrv-n1.conf distribution/conf/controller/quick-start/namesrv.conf distribution/conf/controller/quick-start/broker-n1.conf distribution/conf/controller/quick-start/broker-n0.conf distribution/conf/controller/cluster-3n-independent/controller-n2.conf distribution/conf/controller/cluster-3n-independent/controller-n1.conf distribution/conf/controller/cluster-3n-independent/controller-n0.conf distribution/conf/controller/controller-standalone.conf distribution/conf/container/2container-2m-2s/broker-b-in-container1.conf distribution/conf/container/2container-2m-2s/nameserver.conf distribution/conf/container/2container-2m-2s/broker-a-in-container1.conf distribution/conf/container/2container-2m-2s/broker-a-in-container2.conf distribution/conf/container/2container-2m-2s/broker-container2.conf distribution/conf/container/2container-2m-2s/broker-b-in-container2.conf distribution/conf/container/2container-2m-2s/broker-container1.conf distribution/conf/dledger/broker-n1.conf distribution/conf/dledger/broker-n2.conf distribution/conf/dledger/broker-n0.conf distribution/conf/broker.conf proxy/src/test/resources/rmq-proxy-home/conf/broker.conf test/src/test/resources/rmq-proxy-home/conf/broker.conf - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.yaml files (19): distribution/conf/tools.yml .github/workflows/pr-e2e-test.yml .github/workflows/bazel.yml .github/workflows/codeql_analysis.yml .github/workflows/integration-test.yml .github/workflows/coverage.yml .github/workflows/stale.yml .github/workflows/pr-ci.yml .github/workflows/misspell_check.yml .github/workflows/push-ci.yml .github/workflows/snapshot-automation.yml .github/workflows/rerun-workflow.yml .github/ISSUE_TEMPLATE/feature_request.yml .github/ISSUE_TEMPLATE/enhancement_request.yml .github/ISSUE_TEMPLATE/bug_report.yml .github/ISSUE_TEMPLATE/doc.yml .github/ISSUE_TEMPLATE/config.yml client/src/test/resources/conf/plain_acl_incomplete.yml client/src/test/resources/acl_hook/plain_acl.yml - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.bazel files (18): filter/BUILD.bazel tools/BUILD.bazel common/BUILD.bazel bazel/BUILD.bazel srvutil/BUILD.bazel BUILD.bazel broker/BUILD.bazel store/BUILD.bazel client/BUILD.bazel remoting/BUILD.bazel proxy/BUILD.bazel controller/BUILD.bazel container/BUILD.bazel namesrv/BUILD.bazel tieredstore/BUILD.bazel MODULE.bazel test/BUILD.bazel auth/BUILD.bazel - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *. files (13): distribution/bin/mqbroker distribution/bin/mqcontroller distribution/bin/mqproxy distribution/bin/mqnamesrv distribution/bin/mqshutdown distribution/bin/mqadmin distribution/bin/mqbrokercontainer distribution/NOTICE-BIN distribution/LICENSE-BIN BUILDING LICENSE NOTICE WORKSPACE - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.pem files (6): remoting/src/test/resources/certs/server.pem remoting/src/test/resources/certs/badClient.pem remoting/src/test/resources/certs/privkey.pem remoting/src/test/resources/certs/ca.pem remoting/src/test/resources/certs/client.pem remoting/src/test/resources/certs/badServer.pem - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.key files (4): remoting/src/test/resources/certs/server.key remoting/src/test/resources/certs/badServer.key remoting/src/test/resources/certs/client.key remoting/src/test/resources/certs/badClient.key - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.jj files (1): filter/src/main/java/org/apache/rocketmq/filter/parser/SelectorParser.jj - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.mockmaker files (1): proxy/src/test/resources/mockito-extensions/org.mockito.plugins.MockMaker - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.bazelversion files (1): .bazelversion - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.configurator files (1): common/src/main/resources/META-INF/services/org.apache.rocketmq.logging.ch.qos.logback.classic.spi.Configurator - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.abstracttransactionalmessagechecklistener files (1): broker/src/test/resources/META-INF/service/org.apache.rocketmq.broker.transaction.AbstractTransactionalMessageCheckListener - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.numanode0 files (1): distribution/bin/mqbroker.numanode0 - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.numanode1 files (1): distribution/bin/mqbroker.numanode1 - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.numanode2 files (1): distribution/bin/mqbroker.numanode2 - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.transactionalmessageservice files (1): broker/src/test/resources/META-INF/service/org.apache.rocketmq.broker.transaction.TransactionalMessageService - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.numanode3 files (1): distribution/bin/mqbroker.numanode3 - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - *.bazelrc files (1): .bazelrc - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - - -