You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by aa...@apache.org on 2022/06/17 09:38:55 UTC
[rocketmq-clients] branch master updated (515c9db -> c46823c)
This is an automated email from the ASF dual-hosted git repository.
aaronai pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
from 515c9db Enable wiki, issue, projects and merge buttons GitHub features
new 77306f3 Initial commit
new e2551fa Fix RetrySendCallback member naming
new f0cbcf7 Create main.yml
new d73199c Set bazel version for github action
new 4e00482 Fix deps issue for //src/test/cpp/it:it_topic_publish_info
new 4cb2d48 Add sha256 for absl and protobuf
new 2b4fbdd Use bazel-remote
new 373c45a Remove ConfigFileCredentialsProvider unit test for now
new c25b33a Add build badge
new fb4ea7d Generate coverage
new 3554732 Add script to calculate coverage
new e233600 Run coverage in CI
new 02aa5e7 Fix compile issue
new e457895 Run ci for develop branch
new d10862f Use secrets to access bazel remote cache
new a1bce20 1. Refactor to use async mechanism internally 2. Minimize third-party dependencies
new 937200c Add send function with message_group argument
new 597d312 Add STS credentials provider
new 6a04948 Support FIFO message pub/sub (#5)
new bc3a7e9 STS bears Security Token header when making requests (#6)
new 36891e8 Use macro when declaring namespace
new 5b518a5 Create LICENSE
new 71422e0 Remove unused file
new 3d1927e Remove bazel remote cache
new 2b26470 Add unit test for HostInfo
new 2fdd390 Debug MessageTest
new 6ef43ca BugFix: fix MQMessage
new 67b53ed Improve unit test coverage for base module (#7)
new 0a4ff04 Improve unit test coverage for client module (#8)
new 8ee91d7 Enhance coverage of the rocketmq module (#9)
new dd1becc Add unit test for InvocationContext.h
new 36be701 Add trival unit test
new a977afa Add unit test for PullConsumerImpl (#10)
new 5ec9131 Add more unit tests for PullConsumerImpl
new 72d4f0b Add more tests for PullConsumerImpl
new 4174095 Add unit test for ClientImpl (#11)
new 89278ae BugFix: Fix ProcessQueue#filterExpression issue
new bcc418e Improvement: use absl::optional where it makes sense
new f0a8c65 Remove unused files
new a7d92e2 Specify coverage html directory
new f099c0e Prefix unique ID with version
new 6c8ade3 Add unit tests for log module (#12)
new 77fdd16 Update proto files
new eded8ea Fix CMakeLists.txt
new 22ce81a Fix CMakeLists.txt and bazel 3rd party deps (#13)
new e74408a Support tracing (#14)
new da3e1db Remove unused third party libraries
new d10f5ba Remove unused third party libraries
new a06a84d Minor fix while debug
new 6f2832a Fetch topic route with name server list attached (#15)
new cc64cc3 Adjust logging
new a94d193 Test async producer example
new 0d46de7 Sync consumer (#16)
new 59fe254 Update CMakeLists.txt
new 7e131dc Notify client termination (#17)
new 27af767 Make code compile on Windows (#18)
new a7e7625 Add cpp_httplib-based http-client (#19)
new 7d96cb1 Delete unused includes
new df89fc3 Name server resolver (#20)
new 64388fa Fix logging
new e87b7a2 Fix logging
new 3222428 Polish log
new 74ca811 Log error details to console
new c34e620 Use multiple runner
new 9f0e46d Test support of multiple runners
new de37bcf Revert runs-on
new c7a6cdd Fix Transactional Message Bugs (#21)
new 2c1969d Fix unit tests
new 6cebe54 Expose message-id and transaction-id out of Transaction
new 600cb66 Fix group_name issue and virtual inheritance issue (#22)
new cf6c141 Fix include order
new 9540691 Unify API
new c99d515 Improve Error Handling (#23)
new 3cb0274 Improve error handling of NotifyClientTermination
new 59c9878 BugFix: Add signature
new a4338df BugFix: fix pull-message missing signature metadata
new bb236ce Guard io_context#run with try-catch
new b59fb68 Make exceptions into account for Scheduler and thread-pool
new 0e35529 Fix order consumer (#24)
new a89a937 Polish code
new 4baf865 Broadcasting (#25)
new ee9120e Set gRPC max message size
new 7e764b6 Log RPC latency
new 1c7474b Change ReceiveMessageResponse to trace
new ee61a08 Fix log level
new ffdab29 Trim response-text in log interceptor
new f19a237 Use latest protocol definition (#26)
new 8eeb232 Configure Keep-alive ping and disable client retries (#27)
new 9bd65be BugFix: fix DEBUG enum item and macro collision
new 51ff3c1 Set default logger level
new 7354d7a Add sha256 for asio and httplib
new 8ecf035 Use latest protocol specification
new fdac606 Fix unit tests
new a03788c Add unit test for remoting protocol
new 42762d0 Fix compile warning
new 332f2e8 Adapt to protocol v1.0-alpha1 (#29)
new 3dc6ee8 Set group when end-transaction
new 2b9aafb Install bazel from official repository
new 4bc0e35 Update main.yml
new 6984b94 Add utility to fix file header copyright comment
new a0db0cb BugFix: Add copyright file header comment
new 111ddaf Remove CMake script files
new 7cc2efc Format all source files
new 55bccfc Set --color=yes
new 5ba187a Format code (#369)
new a7184b2 Allow configuring custom offset-store
new 46444c2 BugFix: forward system attributes
new 33b0cee Bugfix: Compare and initiate poll-command-cycle when topic route is updated (#371)
new d515ca5 Fix log
new cc2af6d Bugfix: map iterator is out of bounds (#372)
new 26223ed Export trace-id and span-id using raw data (#374)
new f8836bd Messages assign unique message identifiers in constructor and reuse them when filling send message request (#375)
new 2be2f7c Polish Scheduler implementation (#373)
new 3b3ef00 Update README.md
new 9555dae Update rocketmq trace attributes key name (#376)
new bffad4f Implmenet trace for message sending (#377)
new 6548bab Implement trace for standard consumption (#378)
new 925915f Remove unused test cases
new 8f45618 Optimize SchedulerTest
new 8a81392 Bump version to 5.0.0 (#379)
new 8be2aa7 Add more attributes for message consumption (#380)
new fe52d1d Implement trace for fifo consumption (#381)
new 88998c2 Bugfix: wrong judgement to submit fifo consumption task (#382)
new 2b03186 Try to submit consume-task for the current process-queue its own task completed
new b066034 Fill 'messaging.rocketmq.message_keys' attribute in message tracing with value of array (#383)
new 7c5df12 Add 'message' into the arguments of transaction related method (#384)
new 9959686 Implement trace for transaction message (#385)
new ab3fdf9 Enable message tracing in default mode (#388)
new 571c7b7 Use gRPC naming scheme for name server address (#408)
new a44a2c6 Adopt protocol v2 (#414)
new 28a0054 Unify standard and FIFO message processing implementation
new e7d188a Instrument with opencensus to collect various metrics (#415)
new 7fc8d4f Remove stages of running unit tests
new c233dee Integret current repo with rocketmq clients
new 254e3a9 Merge branch 'main' into clients
new e6a6bb9 Initial commit
new c7d22e2 Update README.md, adding a brief introduction to archicture; adding license file
new 9c5b36e Add instruction on build, test and running examples
new f94a0be Setup infra for application layer development (#1)
new cbe22d2 Implement and Test RPC QueryRoute, Heartbeat and Implement Producer basic logic (#2)
new 9563341 Create Unit Tests for SendMessage and NotifyClientTermination (#3)
new 837f36b Complete the basic send procedure (#5)
new 6b3a3b0 Implement MessageIdGenerator (#4)
new afe3c46 Apply nlog as logging system for rocketmq-client (#6)
new 80f7bc0 Setup continuous integration (#8)
new 6b9c567 Fix typo (#7)
new f9abf8c Enable wiki, issues and project features of github
new 5576b51 Integret current repo with rocketmq clients
new 014e0d8 Merge branch 'csharp' into clients
new c46823c Merge pull request #1 from aaron-ai/pr
The 152 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:
.github/workflows/main.yml | 18 +
.gitignore | 6 +
.vscode/settings.json | 17 +
cpp/.bazelignore | 2 +
cpp/.bazelrc | 138 +++
cpp/.bazelversion | 1 +
cpp/.clang-format | 28 +
cpp/.clang-tidy | 81 ++
cpp/.gitignore | 20 +
cpp/.travis.yml | 173 ++++
cpp/BUILD.bazel | 16 +
cpp/LICENSE | 201 ++++
cpp/README.md | 92 ++
cpp/WORKSPACE | 20 +
cpp/api/BUILD.bazel | 28 +
cpp/api/rocketmq/AdminServer.h | 41 +
cpp/api/rocketmq/BackoffPolicy.h | 70 ++
cpp/api/rocketmq/Configuration.h | 71 ++
cpp/api/rocketmq/ConfigurationDefaults.h | 34 +
cpp/api/rocketmq/ConsumeResult.h | 30 +
cpp/api/rocketmq/Credentials.h | 83 ++
cpp/api/rocketmq/CredentialsProvider.h | 110 ++
cpp/api/rocketmq/ErrorCategory.h | 40 +
cpp/api/rocketmq/ErrorCode.h | 183 ++++
cpp/api/rocketmq/Executor.h | 27 +
cpp/api/rocketmq/ExpressionType.h | 31 +
cpp/api/rocketmq/FilterExpression.h | 46 +
cpp/api/rocketmq/Logger.h | 72 ++
cpp/api/rocketmq/MQClientException.h | 97 ++
cpp/api/rocketmq/Message.h | 180 ++++
cpp/api/rocketmq/MessageListener.h | 28 +
cpp/api/rocketmq/Producer.h | 95 ++
cpp/api/rocketmq/PushConsumer.h | 94 ++
cpp/api/rocketmq/RocketMQ.h | 24 +
cpp/api/rocketmq/SendCallback.h | 29 +
cpp/api/rocketmq/SendReceipt.h | 33 +
cpp/api/rocketmq/SimpleConsumer.h | 111 ++
cpp/api/rocketmq/State.h | 34 +
cpp/api/rocketmq/Tracing.h | 27 +
cpp/api/rocketmq/Transaction.h | 51 +
cpp/api/rocketmq/TransactionChecker.h | 28 +
cpp/api/rocketmq/TransactionState.h | 30 +
cpp/bazel/BUILD.bazel | 16 +
cpp/bazel/curl.bzl | 201 ++++
cpp/bazel/rocketmq_deps.bzl | 170 +++
cpp/ci/build.sh | 10 +
cpp/docs/assets/BasicMode.png | Bin 0 -> 42779 bytes
cpp/docs/assets/class_diagram.png | Bin 0 -> 364206 bytes
cpp/docs/gtest.md | 8 +
cpp/docs/test_coverage.md | 15 +
cpp/examples/BUILD.bazel | 137 +++
cpp/examples/BenchmarkPushConsumer.cpp | 83 ++
cpp/examples/ExampleAsyncProducer.cpp | 113 ++
cpp/examples/ExampleFifoProducer.cpp | 99 ++
cpp/examples/ExampleFifoPushConsumer.cpp | 67 ++
cpp/examples/ExampleProducer.cpp | 94 ++
cpp/examples/ExamplePushConsumer.cpp | 50 +
cpp/examples/ExampleSimpleConsumer.cpp | 66 ++
cpp/examples/ExampleTransactionProducer.cpp | 52 +
cpp/examples/PushConsumerWithCustomExecutor.cpp | 147 +++
cpp/examples/PushConsumerWithThrottle.cpp | 88 ++
cpp/examples/SqlConsumer.cpp | 61 ++
cpp/examples/SqlProducer.cpp | 60 ++
cpp/proto/BUILD.bazel | 79 ++
cpp/proto/apache/rocketmq/v2/admin.proto | 43 +
cpp/proto/apache/rocketmq/v2/definition.proto | 444 ++++++++
cpp/proto/apache/rocketmq/v2/service.proto | 457 ++++++++
cpp/src/main/cpp/admin/AdminClient.cpp | 111 ++
cpp/src/main/cpp/admin/AdminFacade.cpp | 24 +
cpp/src/main/cpp/admin/AdminServerImpl.cpp | 119 +++
cpp/src/main/cpp/admin/AdminServiceImpl.cpp | 65 ++
cpp/src/main/cpp/admin/BUILD.bazel | 59 ++
cpp/src/main/cpp/admin/include/AdminClient.h | 45 +
cpp/src/main/cpp/admin/include/AdminServerImpl.h | 64 ++
cpp/src/main/cpp/admin/include/AdminServiceImpl.h | 37 +
cpp/src/main/cpp/admin/include/ServerCall.h | 82 ++
cpp/src/main/cpp/base/BUILD.bazel | 46 +
cpp/src/main/cpp/base/Configuration.cpp | 45 +
cpp/src/main/cpp/base/ConfigurationDefaults.cpp | 25 +
cpp/src/main/cpp/base/CredentialsProvider.cpp | 210 ++++
cpp/src/main/cpp/base/ErrorCategory.cpp | 116 +++
cpp/src/main/cpp/base/ErrorCode.cpp | 26 +
cpp/src/main/cpp/base/FilterExpression.cpp | 41 +
cpp/src/main/cpp/base/HostInfo.cpp | 77 ++
cpp/src/main/cpp/base/HttpClientImpl.cpp | 90 ++
cpp/src/main/cpp/base/Message.cpp | 89 ++
cpp/src/main/cpp/base/MessageExt.cpp | 33 +
cpp/src/main/cpp/base/MetadataConstants.cpp | 52 +
cpp/src/main/cpp/base/MixAll.cpp | 325 ++++++
cpp/src/main/cpp/base/Protocol.cpp | 153 +++
cpp/src/main/cpp/base/RateLimiter.cpp | 54 +
cpp/src/main/cpp/base/ThreadPoolImpl.cpp | 100 ++
cpp/src/main/cpp/base/TopAddressing.cpp | 76 ++
cpp/src/main/cpp/base/Tracing.cpp | 26 +
cpp/src/main/cpp/base/UniqueIdGenerator.cpp | 90 ++
cpp/src/main/cpp/base/UtilAll.cpp | 204 ++++
cpp/src/main/cpp/base/include/Histogram.h | 85 ++
cpp/src/main/cpp/base/include/HostInfo.h | 47 +
cpp/src/main/cpp/base/include/HttpClient.h | 53 +
cpp/src/main/cpp/base/include/HttpClientImpl.h | 46 +
cpp/src/main/cpp/base/include/InvocationContext.h | 105 ++
cpp/src/main/cpp/base/include/MessageExt.h | 31 +
cpp/src/main/cpp/base/include/MetadataConstants.h | 44 +
cpp/src/main/cpp/base/include/MixAll.h | 173 ++++
cpp/src/main/cpp/base/include/Protocol.h | 92 ++
cpp/src/main/cpp/base/include/RateLimiter.h | 184 ++++
cpp/src/main/cpp/base/include/RetryPolicy.h | 81 ++
.../cpp/base/include/StsCredentialsProviderImpl.h | 61 ++
cpp/src/main/cpp/base/include/SubscriptionEntry.h | 33 +
cpp/src/main/cpp/base/include/ThreadPool.h | 36 +
cpp/src/main/cpp/base/include/ThreadPoolImpl.h | 57 +
cpp/src/main/cpp/base/include/TopAddressing.h | 52 +
cpp/src/main/cpp/base/include/UniqueIdGenerator.h | 82 ++
cpp/src/main/cpp/base/include/UtilAll.h | 45 +
cpp/src/main/cpp/base/mocks/BUILD.bazel | 28 +
.../main/cpp/base/mocks/include/HttpClientMock.h | 37 +
.../cpp/base/mocks/include/MessageListenerMock.h | 34 +
cpp/src/main/cpp/base/tests/AssignmentTest.cpp | 23 +
cpp/src/main/cpp/base/tests/BUILD.bazel | 54 +
cpp/src/main/cpp/base/tests/ConfigurationTest.cpp | 54 +
cpp/src/main/cpp/base/tests/MessageBuilderTest.cpp | 56 +
cpp/src/main/cpp/base/tests/MessageQueueTest.cpp | 21 +
cpp/src/main/cpp/base/tests/MixAllTest.cpp | 27 +
cpp/src/main/cpp/base/tests/RetryPolicyTest.cpp | 33 +
cpp/src/main/cpp/client/BUILD.bazel | 41 +
cpp/src/main/cpp/client/ClientManagerFactory.cpp | 62 ++
cpp/src/main/cpp/client/ClientManagerImpl.cpp | 1088 ++++++++++++++++++++
cpp/src/main/cpp/client/LogInterceptor.cpp | 97 ++
cpp/src/main/cpp/client/LogInterceptorFactory.cpp | 27 +
.../main/cpp/client/ReceiveMessageStreamReader.cpp | 118 +++
cpp/src/main/cpp/client/RpcClientImpl.cpp | 173 ++++
cpp/src/main/cpp/client/SessionImpl.cpp | 45 +
cpp/src/main/cpp/client/Signature.cpp | 73 ++
cpp/src/main/cpp/client/TelemetryBidiReactor.cpp | 347 +++++++
cpp/src/main/cpp/client/TlsHelper.cpp | 41 +
cpp/src/main/cpp/client/TopicAssignmentInfo.cpp | 59 ++
cpp/src/main/cpp/client/include/Client.h | 66 ++
cpp/src/main/cpp/client/include/ClientConfig.h | 66 ++
cpp/src/main/cpp/client/include/ClientManager.h | 105 ++
.../main/cpp/client/include/ClientManagerFactory.h | 57 +
.../main/cpp/client/include/ClientManagerImpl.h | 241 +++++
.../main/cpp/client/include/ConsumeMessageType.h | 31 +
.../cpp/client/include/HeartbeatDataCallback.h | 31 +
.../client/include/InsecureCertificateVerifier.h | 42 +
.../cpp/client/include/InterceptorContinuation.h | 45 +
cpp/src/main/cpp/client/include/LogInterceptor.h | 34 +
.../cpp/client/include/LogInterceptorFactory.h | 30 +
cpp/src/main/cpp/client/include/Metadata.h | 27 +
.../main/cpp/client/include/OpenSSLCompatible.h | 390 +++++++
.../cpp/client/include/ReceiveMessageCallback.h | 28 +
.../cpp/client/include/ReceiveMessageContext.h | 36 +
.../main/cpp/client/include/ReceiveMessageResult.h | 43 +
.../client/include/ReceiveMessageStreamReader.h | 63 ++
cpp/src/main/cpp/client/include/RpcClient.h | 106 ++
cpp/src/main/cpp/client/include/RpcClientImpl.h | 105 ++
.../main/cpp/client/include/SendMessageContext.h | 73 ++
cpp/src/main/cpp/client/include/Session.h | 30 +
cpp/src/main/cpp/client/include/SessionImpl.h | 45 +
cpp/src/main/cpp/client/include/Signature.h | 30 +
.../main/cpp/client/include/TelemetryBidiReactor.h | 121 +++
cpp/src/main/cpp/client/include/TlsHelper.h | 32 +
cpp/src/main/cpp/client/include/Topic.h | 64 ++
.../main/cpp/client/include/TopicAssignmentInfo.h | 59 ++
.../cpp/client/include/TopicRouteChangeCallback.h | 30 +
cpp/src/main/cpp/client/include/TopicRouteData.h | 67 ++
cpp/src/main/cpp/client/mocks/BUILD.bazel | 29 +
.../cpp/client/mocks/include/ClientManagerMock.h | 99 ++
cpp/src/main/cpp/client/mocks/include/ClientMock.h | 46 +
.../mocks/include/ReceiveMessageCallbackMock.h | 30 +
.../main/cpp/client/mocks/include/RpcClientMock.h | 79 ++
cpp/src/main/cpp/concurrent/BUILD.bazel | 37 +
cpp/src/main/cpp/concurrent/CountdownLatch.cpp | 52 +
.../main/cpp/concurrent/include/CountdownLatch.h | 51 +
cpp/src/main/cpp/log/BUILD.bazel | 29 +
cpp/src/main/cpp/log/LoggerImpl.cpp | 136 +++
cpp/src/main/cpp/log/include/LoggerImpl.h | 102 ++
cpp/src/main/cpp/remoting/BUILD.bazel | 32 +
cpp/src/main/cpp/remoting/BrokerData.cpp | 43 +
.../main/cpp/remoting/QueryRouteRequestHeader.cpp | 29 +
cpp/src/main/cpp/remoting/QueueData.cpp | 49 +
cpp/src/main/cpp/remoting/RemotingCommand.cpp | 113 ++
cpp/src/main/cpp/remoting/TopicRouteData.cpp | 46 +
cpp/src/main/cpp/remoting/include/BrokerData.h | 38 +
.../cpp/remoting/include/CommandCustomHeader.h | 33 +
cpp/src/main/cpp/remoting/include/LanguageCode.h | 41 +
.../cpp/remoting/include/QueryRouteRequestHeader.h | 46 +
cpp/src/main/cpp/remoting/include/QueueData.h | 44 +
.../main/cpp/remoting/include/RemotingCommand.h | 106 ++
.../cpp/remoting/include/RemotingCommandType.h | 31 +
cpp/src/main/cpp/remoting/include/RequestCode.h | 32 +
cpp/src/main/cpp/remoting/include/ResponseCode.h | 32 +
cpp/src/main/cpp/remoting/include/TopicRouteData.h | 44 +
cpp/src/main/cpp/remoting/include/Version.h | 31 +
.../cpp/rocketmq/AsyncReceiveMessageCallback.cpp | 116 +++
cpp/src/main/cpp/rocketmq/BUILD.bazel | 34 +
cpp/src/main/cpp/rocketmq/ClientImpl.cpp | 539 ++++++++++
.../cpp/rocketmq/ConsumeMessageServiceImpl.cpp | 150 +++
cpp/src/main/cpp/rocketmq/ConsumeTask.cpp | 182 ++++
.../cpp/rocketmq/DynamicNameServerResolver.cpp | 129 +++
.../cpp/rocketmq/MessageGroupQueueSelector.cpp | 35 +
cpp/src/main/cpp/rocketmq/NamingScheme.cpp | 89 ++
cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp | 250 +++++
cpp/src/main/cpp/rocketmq/Producer.cpp | 96 ++
cpp/src/main/cpp/rocketmq/ProducerImpl.cpp | 580 +++++++++++
cpp/src/main/cpp/rocketmq/PushConsumer.cpp | 53 +
cpp/src/main/cpp/rocketmq/PushConsumerImpl.cpp | 562 ++++++++++
cpp/src/main/cpp/rocketmq/SendContext.cpp | 118 +++
cpp/src/main/cpp/rocketmq/SimpleConsumer.cpp | 141 +++
cpp/src/main/cpp/rocketmq/SimpleConsumerImpl.cpp | 400 +++++++
.../main/cpp/rocketmq/StaticNameServerResolver.cpp | 38 +
cpp/src/main/cpp/rocketmq/TopicPublishInfo.cpp | 125 +++
cpp/src/main/cpp/rocketmq/TransactionImpl.cpp | 48 +
.../rocketmq/include/AsyncReceiveMessageCallback.h | 52 +
cpp/src/main/cpp/rocketmq/include/ClientImpl.h | 213 ++++
.../cpp/rocketmq/include/ClientResourceBundle.h | 38 +
.../cpp/rocketmq/include/ConsumeMessageService.h | 71 ++
.../rocketmq/include/ConsumeMessageServiceImpl.h | 87 ++
cpp/src/main/cpp/rocketmq/include/ConsumeTask.h | 87 ++
cpp/src/main/cpp/rocketmq/include/Consumer.h | 45 +
.../rocketmq/include/DynamicNameServerResolver.h | 73 ++
.../rocketmq/include/MessageGroupQueueSelector.h | 36 +
.../main/cpp/rocketmq/include/NameServerResolver.h | 37 +
cpp/src/main/cpp/rocketmq/include/NamingScheme.h | 50 +
cpp/src/main/cpp/rocketmq/include/ProcessQueue.h | 71 ++
.../main/cpp/rocketmq/include/ProcessQueueImpl.h | 176 ++++
cpp/src/main/cpp/rocketmq/include/ProducerImpl.h | 166 +++
.../cpp/rocketmq/include/PublishInfoCallback.h | 28 +
.../main/cpp/rocketmq/include/PushConsumerImpl.h | 225 ++++
cpp/src/main/cpp/rocketmq/include/SendContext.h | 79 ++
.../main/cpp/rocketmq/include/SimpleConsumerImpl.h | 89 ++
.../rocketmq/include/StaticNameServerResolver.h | 53 +
.../main/cpp/rocketmq/include/TopicPublishInfo.h | 63 ++
.../main/cpp/rocketmq/include/TransactionImpl.h | 76 ++
cpp/src/main/cpp/rocketmq/mocks/BUILD.bazel | 28 +
.../mocks/include/ConsumeMessageServiceMock.h | 40 +
.../main/cpp/rocketmq/mocks/include/ConsumerMock.h | 37 +
.../mocks/include/NameServerResolverMock.h | 33 +
.../cpp/rocketmq/mocks/include/ProcessQueueMock.h | 63 ++
.../cpp/rocketmq/mocks/include/PushConsumerMock.h | 49 +
cpp/src/main/cpp/rocketmq/tests/BUILD.bazel | 38 +
.../main/cpp/rocketmq/tests/SendContextTest.cpp | 17 +
cpp/src/main/cpp/rocketmq/tests/TimeTest.cpp | 31 +
cpp/src/main/cpp/scheduler/BUILD.bazel | 32 +
cpp/src/main/cpp/scheduler/SchedulerImpl.cpp | 195 ++++
cpp/src/main/cpp/scheduler/include/Scheduler.h | 46 +
cpp/src/main/cpp/scheduler/include/SchedulerImpl.h | 90 ++
cpp/src/main/cpp/stats/BUILD.bazel | 30 +
cpp/src/main/cpp/stats/ConsumeStats.cpp | 148 +++
cpp/src/main/cpp/stats/MetricBidiReactor.cpp | 116 +++
cpp/src/main/cpp/stats/OpencensusExporter.cpp | 190 ++++
cpp/src/main/cpp/stats/PublishStats.cpp | 56 +
cpp/src/main/cpp/stats/Tag.cpp | 41 +
cpp/src/main/cpp/stats/include/ConsumeStats.h | 87 ++
cpp/src/main/cpp/stats/include/Exporter.h | 30 +
cpp/src/main/cpp/stats/include/MetricBidiReactor.h | 78 ++
.../main/cpp/stats/include/OpencensusExporter.h | 53 +
cpp/src/main/cpp/stats/include/PublishStats.h | 49 +
cpp/src/main/cpp/stats/include/Tag.h | 35 +
cpp/src/main/cpp/stats/tests/BUILD.bazel | 28 +
cpp/src/main/cpp/stats/tests/PublishStatsTest.cpp | 157 +++
cpp/src/main/cpp/trace/BUILD.bazel | 29 +
cpp/src/main/cpp/trace/TracingUtility.cpp | 87 ++
cpp/src/main/cpp/trace/include/TracingUtility.h | 32 +
cpp/third_party/BUILD.bazel | 16 +
cpp/third_party/ThreadPool.BUILD | 11 +
cpp/third_party/asio.BUILD | 17 +
cpp/third_party/cpp_httplib.BUILD | 17 +
cpp/third_party/curl.BUILD | 35 +
cpp/third_party/filesystem.BUILD | 9 +
cpp/third_party/fmtlib.BUILD | 12 +
cpp/third_party/spdlog.BUILD | 21 +
cpp/tools/copyright.txt | 14 +
cpp/tools/coverage.sh | 17 +
cpp/tools/fix_copyright.py | 59 ++
cpp/tools/format.sh | 6 +
cpp/tools/trouble_shooting.sh | 2 +
cpp/tools/use_clang.sh | 2 +
csharp/LICENSE | 201 ++++
csharp/NOTICE | 7 +
csharp/README.md | 44 +
csharp/examples/Program.cs | 61 ++
csharp/examples/examples.csproj | 12 +
csharp/rocketmq-client-csharp/Address.cs | 35 +
csharp/rocketmq-client-csharp/AddressScheme.cs | 23 +
csharp/rocketmq-client-csharp/Broker.cs | 77 ++
csharp/rocketmq-client-csharp/Client.cs | 262 +++++
csharp/rocketmq-client-csharp/ClientConfig.cs | 125 +++
.../ClientLoggerInterceptor.cs | 134 +++
csharp/rocketmq-client-csharp/ClientManager.cs | 182 ++++
.../rocketmq-client-csharp/ClientManagerFactory.cs | 45 +
.../ConfigFileCredentialsProvider.cs | 63 ++
csharp/rocketmq-client-csharp/Credentials.cs | 65 ++
csharp/rocketmq-client-csharp/IClient.cs | 32 +
csharp/rocketmq-client-csharp/IClientConfig.cs | 41 +
csharp/rocketmq-client-csharp/IClientManager.cs | 36 +
.../rocketmq-client-csharp/ICredentialsProvider.cs | 21 +
.../rocketmq-client-csharp/INameServerResolver.cs | 27 +
csharp/rocketmq-client-csharp/IProducer.cs | 29 +
csharp/rocketmq-client-csharp/IRpcClient.cs | 34 +
csharp/rocketmq-client-csharp/Message.cs | 92 ++
.../rocketmq-client-csharp/MessageIdGenerator.cs | 104 ++
csharp/rocketmq-client-csharp/MessageType.cs | 28 +
csharp/rocketmq-client-csharp/MetadataConstants.cs | 37 +
csharp/rocketmq-client-csharp/MqLogManager.cs | 34 +
csharp/rocketmq-client-csharp/Partition.cs | 85 ++
csharp/rocketmq-client-csharp/Permission.cs | 23 +
csharp/rocketmq-client-csharp/Producer.cs | 136 +++
.../Protos/apache/rocketmq/v1/admin.proto | 45 +
.../Protos/apache/rocketmq/v1/definition.proto | 351 +++++++
.../Protos/apache/rocketmq/v1/service.proto | 522 ++++++++++
.../Protos/google/rpc/code.proto | 186 ++++
.../Protos/google/rpc/error_details.proto | 249 +++++
.../Protos/google/rpc/status.proto | 47 +
.../rocketmq-client-csharp/PublishLoadBalancer.cs | 119 +++
csharp/rocketmq-client-csharp/RpcClient.cs | 61 ++
csharp/rocketmq-client-csharp/SendResult.cs | 41 +
csharp/rocketmq-client-csharp/SendStatus.cs | 25 +
csharp/rocketmq-client-csharp/SequenceGenerator.cs | 128 +++
csharp/rocketmq-client-csharp/ServiceAddress.cs | 39 +
csharp/rocketmq-client-csharp/Signature.cs | 67 ++
.../StaticCredentialsProvider.cs | 32 +
.../StaticNameServerResolver.cs | 38 +
csharp/rocketmq-client-csharp/Topic.cs | 66 ++
csharp/rocketmq-client-csharp/TopicRouteData.cs | 56 +
.../rocketmq-client-csharp/TopicRouteException.cs | 28 +
csharp/rocketmq-client-csharp/Utilities.cs | 53 +
.../rocketmq-client-csharp.csproj | 39 +
.../rocketmq-client-csharp.nlog | 27 +
csharp/rocketmq-client.sln | 62 ++
csharp/tests/BrokerTest.cs | 38 +
csharp/tests/ClientConfigTest.cs | 31 +
csharp/tests/ClientManagerTest.cs | 57 +
csharp/tests/ConfigFileCredentialsProviderTest.cs | 31 +
csharp/tests/DateTimeTest.cs | 34 +
csharp/tests/MessageIdGeneratorTest.cs | 42 +
csharp/tests/MessageTest.cs | 114 ++
csharp/tests/MqLogManagerTest.cs | 27 +
csharp/tests/ProducerTest.cs | 74 ++
csharp/tests/RpcClientTest.cs | 163 +++
csharp/tests/SendResultTest.cs | 44 +
csharp/tests/SequenceGeneratorTest.cs | 49 +
csharp/tests/SignatureTest.cs | 48 +
csharp/tests/StaticCredentialsProviderTest.cs | 37 +
csharp/tests/StaticNameServerResolverTest.cs | 35 +
csharp/tests/TopicTest.cs | 48 +
csharp/tests/UnitTest1.cs | 50 +
csharp/tests/tests.csproj | 21 +
347 files changed, 28008 insertions(+)
create mode 100644 .github/workflows/main.yml
create mode 100644 .gitignore
create mode 100644 .vscode/settings.json
create mode 100644 cpp/.bazelignore
create mode 100644 cpp/.bazelrc
create mode 100644 cpp/.bazelversion
create mode 100644 cpp/.clang-format
create mode 100644 cpp/.clang-tidy
create mode 100644 cpp/.gitignore
create mode 100644 cpp/.travis.yml
create mode 100644 cpp/BUILD.bazel
create mode 100644 cpp/LICENSE
create mode 100644 cpp/README.md
create mode 100644 cpp/WORKSPACE
create mode 100644 cpp/api/BUILD.bazel
create mode 100644 cpp/api/rocketmq/AdminServer.h
create mode 100644 cpp/api/rocketmq/BackoffPolicy.h
create mode 100644 cpp/api/rocketmq/Configuration.h
create mode 100644 cpp/api/rocketmq/ConfigurationDefaults.h
create mode 100644 cpp/api/rocketmq/ConsumeResult.h
create mode 100644 cpp/api/rocketmq/Credentials.h
create mode 100644 cpp/api/rocketmq/CredentialsProvider.h
create mode 100644 cpp/api/rocketmq/ErrorCategory.h
create mode 100644 cpp/api/rocketmq/ErrorCode.h
create mode 100644 cpp/api/rocketmq/Executor.h
create mode 100644 cpp/api/rocketmq/ExpressionType.h
create mode 100644 cpp/api/rocketmq/FilterExpression.h
create mode 100644 cpp/api/rocketmq/Logger.h
create mode 100644 cpp/api/rocketmq/MQClientException.h
create mode 100644 cpp/api/rocketmq/Message.h
create mode 100644 cpp/api/rocketmq/MessageListener.h
create mode 100644 cpp/api/rocketmq/Producer.h
create mode 100644 cpp/api/rocketmq/PushConsumer.h
create mode 100644 cpp/api/rocketmq/RocketMQ.h
create mode 100644 cpp/api/rocketmq/SendCallback.h
create mode 100644 cpp/api/rocketmq/SendReceipt.h
create mode 100644 cpp/api/rocketmq/SimpleConsumer.h
create mode 100644 cpp/api/rocketmq/State.h
create mode 100644 cpp/api/rocketmq/Tracing.h
create mode 100644 cpp/api/rocketmq/Transaction.h
create mode 100644 cpp/api/rocketmq/TransactionChecker.h
create mode 100644 cpp/api/rocketmq/TransactionState.h
create mode 100644 cpp/bazel/BUILD.bazel
create mode 100644 cpp/bazel/curl.bzl
create mode 100644 cpp/bazel/rocketmq_deps.bzl
create mode 100755 cpp/ci/build.sh
create mode 100644 cpp/docs/assets/BasicMode.png
create mode 100644 cpp/docs/assets/class_diagram.png
create mode 100644 cpp/docs/gtest.md
create mode 100644 cpp/docs/test_coverage.md
create mode 100644 cpp/examples/BUILD.bazel
create mode 100644 cpp/examples/BenchmarkPushConsumer.cpp
create mode 100644 cpp/examples/ExampleAsyncProducer.cpp
create mode 100644 cpp/examples/ExampleFifoProducer.cpp
create mode 100644 cpp/examples/ExampleFifoPushConsumer.cpp
create mode 100644 cpp/examples/ExampleProducer.cpp
create mode 100644 cpp/examples/ExamplePushConsumer.cpp
create mode 100644 cpp/examples/ExampleSimpleConsumer.cpp
create mode 100644 cpp/examples/ExampleTransactionProducer.cpp
create mode 100644 cpp/examples/PushConsumerWithCustomExecutor.cpp
create mode 100644 cpp/examples/PushConsumerWithThrottle.cpp
create mode 100644 cpp/examples/SqlConsumer.cpp
create mode 100644 cpp/examples/SqlProducer.cpp
create mode 100644 cpp/proto/BUILD.bazel
create mode 100644 cpp/proto/apache/rocketmq/v2/admin.proto
create mode 100644 cpp/proto/apache/rocketmq/v2/definition.proto
create mode 100644 cpp/proto/apache/rocketmq/v2/service.proto
create mode 100644 cpp/src/main/cpp/admin/AdminClient.cpp
create mode 100644 cpp/src/main/cpp/admin/AdminFacade.cpp
create mode 100644 cpp/src/main/cpp/admin/AdminServerImpl.cpp
create mode 100644 cpp/src/main/cpp/admin/AdminServiceImpl.cpp
create mode 100644 cpp/src/main/cpp/admin/BUILD.bazel
create mode 100644 cpp/src/main/cpp/admin/include/AdminClient.h
create mode 100644 cpp/src/main/cpp/admin/include/AdminServerImpl.h
create mode 100644 cpp/src/main/cpp/admin/include/AdminServiceImpl.h
create mode 100644 cpp/src/main/cpp/admin/include/ServerCall.h
create mode 100644 cpp/src/main/cpp/base/BUILD.bazel
create mode 100644 cpp/src/main/cpp/base/Configuration.cpp
create mode 100644 cpp/src/main/cpp/base/ConfigurationDefaults.cpp
create mode 100644 cpp/src/main/cpp/base/CredentialsProvider.cpp
create mode 100644 cpp/src/main/cpp/base/ErrorCategory.cpp
create mode 100644 cpp/src/main/cpp/base/ErrorCode.cpp
create mode 100644 cpp/src/main/cpp/base/FilterExpression.cpp
create mode 100644 cpp/src/main/cpp/base/HostInfo.cpp
create mode 100644 cpp/src/main/cpp/base/HttpClientImpl.cpp
create mode 100644 cpp/src/main/cpp/base/Message.cpp
create mode 100644 cpp/src/main/cpp/base/MessageExt.cpp
create mode 100644 cpp/src/main/cpp/base/MetadataConstants.cpp
create mode 100644 cpp/src/main/cpp/base/MixAll.cpp
create mode 100644 cpp/src/main/cpp/base/Protocol.cpp
create mode 100644 cpp/src/main/cpp/base/RateLimiter.cpp
create mode 100644 cpp/src/main/cpp/base/ThreadPoolImpl.cpp
create mode 100644 cpp/src/main/cpp/base/TopAddressing.cpp
create mode 100644 cpp/src/main/cpp/base/Tracing.cpp
create mode 100644 cpp/src/main/cpp/base/UniqueIdGenerator.cpp
create mode 100644 cpp/src/main/cpp/base/UtilAll.cpp
create mode 100644 cpp/src/main/cpp/base/include/Histogram.h
create mode 100644 cpp/src/main/cpp/base/include/HostInfo.h
create mode 100644 cpp/src/main/cpp/base/include/HttpClient.h
create mode 100644 cpp/src/main/cpp/base/include/HttpClientImpl.h
create mode 100644 cpp/src/main/cpp/base/include/InvocationContext.h
create mode 100644 cpp/src/main/cpp/base/include/MessageExt.h
create mode 100644 cpp/src/main/cpp/base/include/MetadataConstants.h
create mode 100644 cpp/src/main/cpp/base/include/MixAll.h
create mode 100644 cpp/src/main/cpp/base/include/Protocol.h
create mode 100644 cpp/src/main/cpp/base/include/RateLimiter.h
create mode 100644 cpp/src/main/cpp/base/include/RetryPolicy.h
create mode 100644 cpp/src/main/cpp/base/include/StsCredentialsProviderImpl.h
create mode 100644 cpp/src/main/cpp/base/include/SubscriptionEntry.h
create mode 100644 cpp/src/main/cpp/base/include/ThreadPool.h
create mode 100644 cpp/src/main/cpp/base/include/ThreadPoolImpl.h
create mode 100644 cpp/src/main/cpp/base/include/TopAddressing.h
create mode 100644 cpp/src/main/cpp/base/include/UniqueIdGenerator.h
create mode 100644 cpp/src/main/cpp/base/include/UtilAll.h
create mode 100644 cpp/src/main/cpp/base/mocks/BUILD.bazel
create mode 100644 cpp/src/main/cpp/base/mocks/include/HttpClientMock.h
create mode 100644 cpp/src/main/cpp/base/mocks/include/MessageListenerMock.h
create mode 100644 cpp/src/main/cpp/base/tests/AssignmentTest.cpp
create mode 100644 cpp/src/main/cpp/base/tests/BUILD.bazel
create mode 100644 cpp/src/main/cpp/base/tests/ConfigurationTest.cpp
create mode 100644 cpp/src/main/cpp/base/tests/MessageBuilderTest.cpp
create mode 100644 cpp/src/main/cpp/base/tests/MessageQueueTest.cpp
create mode 100644 cpp/src/main/cpp/base/tests/MixAllTest.cpp
create mode 100644 cpp/src/main/cpp/base/tests/RetryPolicyTest.cpp
create mode 100644 cpp/src/main/cpp/client/BUILD.bazel
create mode 100644 cpp/src/main/cpp/client/ClientManagerFactory.cpp
create mode 100644 cpp/src/main/cpp/client/ClientManagerImpl.cpp
create mode 100644 cpp/src/main/cpp/client/LogInterceptor.cpp
create mode 100644 cpp/src/main/cpp/client/LogInterceptorFactory.cpp
create mode 100644 cpp/src/main/cpp/client/ReceiveMessageStreamReader.cpp
create mode 100644 cpp/src/main/cpp/client/RpcClientImpl.cpp
create mode 100644 cpp/src/main/cpp/client/SessionImpl.cpp
create mode 100644 cpp/src/main/cpp/client/Signature.cpp
create mode 100644 cpp/src/main/cpp/client/TelemetryBidiReactor.cpp
create mode 100644 cpp/src/main/cpp/client/TlsHelper.cpp
create mode 100644 cpp/src/main/cpp/client/TopicAssignmentInfo.cpp
create mode 100644 cpp/src/main/cpp/client/include/Client.h
create mode 100644 cpp/src/main/cpp/client/include/ClientConfig.h
create mode 100644 cpp/src/main/cpp/client/include/ClientManager.h
create mode 100644 cpp/src/main/cpp/client/include/ClientManagerFactory.h
create mode 100644 cpp/src/main/cpp/client/include/ClientManagerImpl.h
create mode 100644 cpp/src/main/cpp/client/include/ConsumeMessageType.h
create mode 100644 cpp/src/main/cpp/client/include/HeartbeatDataCallback.h
create mode 100644 cpp/src/main/cpp/client/include/InsecureCertificateVerifier.h
create mode 100644 cpp/src/main/cpp/client/include/InterceptorContinuation.h
create mode 100644 cpp/src/main/cpp/client/include/LogInterceptor.h
create mode 100644 cpp/src/main/cpp/client/include/LogInterceptorFactory.h
create mode 100644 cpp/src/main/cpp/client/include/Metadata.h
create mode 100644 cpp/src/main/cpp/client/include/OpenSSLCompatible.h
create mode 100644 cpp/src/main/cpp/client/include/ReceiveMessageCallback.h
create mode 100644 cpp/src/main/cpp/client/include/ReceiveMessageContext.h
create mode 100644 cpp/src/main/cpp/client/include/ReceiveMessageResult.h
create mode 100644 cpp/src/main/cpp/client/include/ReceiveMessageStreamReader.h
create mode 100644 cpp/src/main/cpp/client/include/RpcClient.h
create mode 100644 cpp/src/main/cpp/client/include/RpcClientImpl.h
create mode 100644 cpp/src/main/cpp/client/include/SendMessageContext.h
create mode 100644 cpp/src/main/cpp/client/include/Session.h
create mode 100644 cpp/src/main/cpp/client/include/SessionImpl.h
create mode 100644 cpp/src/main/cpp/client/include/Signature.h
create mode 100644 cpp/src/main/cpp/client/include/TelemetryBidiReactor.h
create mode 100644 cpp/src/main/cpp/client/include/TlsHelper.h
create mode 100644 cpp/src/main/cpp/client/include/Topic.h
create mode 100644 cpp/src/main/cpp/client/include/TopicAssignmentInfo.h
create mode 100644 cpp/src/main/cpp/client/include/TopicRouteChangeCallback.h
create mode 100644 cpp/src/main/cpp/client/include/TopicRouteData.h
create mode 100644 cpp/src/main/cpp/client/mocks/BUILD.bazel
create mode 100644 cpp/src/main/cpp/client/mocks/include/ClientManagerMock.h
create mode 100644 cpp/src/main/cpp/client/mocks/include/ClientMock.h
create mode 100644 cpp/src/main/cpp/client/mocks/include/ReceiveMessageCallbackMock.h
create mode 100644 cpp/src/main/cpp/client/mocks/include/RpcClientMock.h
create mode 100644 cpp/src/main/cpp/concurrent/BUILD.bazel
create mode 100644 cpp/src/main/cpp/concurrent/CountdownLatch.cpp
create mode 100644 cpp/src/main/cpp/concurrent/include/CountdownLatch.h
create mode 100644 cpp/src/main/cpp/log/BUILD.bazel
create mode 100644 cpp/src/main/cpp/log/LoggerImpl.cpp
create mode 100644 cpp/src/main/cpp/log/include/LoggerImpl.h
create mode 100644 cpp/src/main/cpp/remoting/BUILD.bazel
create mode 100644 cpp/src/main/cpp/remoting/BrokerData.cpp
create mode 100644 cpp/src/main/cpp/remoting/QueryRouteRequestHeader.cpp
create mode 100644 cpp/src/main/cpp/remoting/QueueData.cpp
create mode 100644 cpp/src/main/cpp/remoting/RemotingCommand.cpp
create mode 100644 cpp/src/main/cpp/remoting/TopicRouteData.cpp
create mode 100644 cpp/src/main/cpp/remoting/include/BrokerData.h
create mode 100644 cpp/src/main/cpp/remoting/include/CommandCustomHeader.h
create mode 100644 cpp/src/main/cpp/remoting/include/LanguageCode.h
create mode 100644 cpp/src/main/cpp/remoting/include/QueryRouteRequestHeader.h
create mode 100644 cpp/src/main/cpp/remoting/include/QueueData.h
create mode 100644 cpp/src/main/cpp/remoting/include/RemotingCommand.h
create mode 100644 cpp/src/main/cpp/remoting/include/RemotingCommandType.h
create mode 100644 cpp/src/main/cpp/remoting/include/RequestCode.h
create mode 100644 cpp/src/main/cpp/remoting/include/ResponseCode.h
create mode 100644 cpp/src/main/cpp/remoting/include/TopicRouteData.h
create mode 100644 cpp/src/main/cpp/remoting/include/Version.h
create mode 100644 cpp/src/main/cpp/rocketmq/AsyncReceiveMessageCallback.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/BUILD.bazel
create mode 100644 cpp/src/main/cpp/rocketmq/ClientImpl.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/ConsumeMessageServiceImpl.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/ConsumeTask.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/DynamicNameServerResolver.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/MessageGroupQueueSelector.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/NamingScheme.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/Producer.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/ProducerImpl.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/PushConsumer.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/PushConsumerImpl.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/SendContext.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/SimpleConsumer.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/SimpleConsumerImpl.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/StaticNameServerResolver.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/TopicPublishInfo.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/TransactionImpl.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/include/AsyncReceiveMessageCallback.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/ClientImpl.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/ClientResourceBundle.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/ConsumeMessageService.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/ConsumeMessageServiceImpl.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/ConsumeTask.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/Consumer.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/DynamicNameServerResolver.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/MessageGroupQueueSelector.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/NameServerResolver.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/NamingScheme.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/ProcessQueue.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/ProcessQueueImpl.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/ProducerImpl.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/PublishInfoCallback.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/PushConsumerImpl.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/SendContext.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/SimpleConsumerImpl.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/StaticNameServerResolver.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/TopicPublishInfo.h
create mode 100644 cpp/src/main/cpp/rocketmq/include/TransactionImpl.h
create mode 100644 cpp/src/main/cpp/rocketmq/mocks/BUILD.bazel
create mode 100644 cpp/src/main/cpp/rocketmq/mocks/include/ConsumeMessageServiceMock.h
create mode 100644 cpp/src/main/cpp/rocketmq/mocks/include/ConsumerMock.h
create mode 100644 cpp/src/main/cpp/rocketmq/mocks/include/NameServerResolverMock.h
create mode 100644 cpp/src/main/cpp/rocketmq/mocks/include/ProcessQueueMock.h
create mode 100644 cpp/src/main/cpp/rocketmq/mocks/include/PushConsumerMock.h
create mode 100644 cpp/src/main/cpp/rocketmq/tests/BUILD.bazel
create mode 100644 cpp/src/main/cpp/rocketmq/tests/SendContextTest.cpp
create mode 100644 cpp/src/main/cpp/rocketmq/tests/TimeTest.cpp
create mode 100644 cpp/src/main/cpp/scheduler/BUILD.bazel
create mode 100644 cpp/src/main/cpp/scheduler/SchedulerImpl.cpp
create mode 100644 cpp/src/main/cpp/scheduler/include/Scheduler.h
create mode 100644 cpp/src/main/cpp/scheduler/include/SchedulerImpl.h
create mode 100644 cpp/src/main/cpp/stats/BUILD.bazel
create mode 100644 cpp/src/main/cpp/stats/ConsumeStats.cpp
create mode 100644 cpp/src/main/cpp/stats/MetricBidiReactor.cpp
create mode 100644 cpp/src/main/cpp/stats/OpencensusExporter.cpp
create mode 100644 cpp/src/main/cpp/stats/PublishStats.cpp
create mode 100644 cpp/src/main/cpp/stats/Tag.cpp
create mode 100644 cpp/src/main/cpp/stats/include/ConsumeStats.h
create mode 100644 cpp/src/main/cpp/stats/include/Exporter.h
create mode 100644 cpp/src/main/cpp/stats/include/MetricBidiReactor.h
create mode 100644 cpp/src/main/cpp/stats/include/OpencensusExporter.h
create mode 100644 cpp/src/main/cpp/stats/include/PublishStats.h
create mode 100644 cpp/src/main/cpp/stats/include/Tag.h
create mode 100644 cpp/src/main/cpp/stats/tests/BUILD.bazel
create mode 100644 cpp/src/main/cpp/stats/tests/PublishStatsTest.cpp
create mode 100644 cpp/src/main/cpp/trace/BUILD.bazel
create mode 100644 cpp/src/main/cpp/trace/TracingUtility.cpp
create mode 100644 cpp/src/main/cpp/trace/include/TracingUtility.h
create mode 100644 cpp/third_party/BUILD.bazel
create mode 100644 cpp/third_party/ThreadPool.BUILD
create mode 100644 cpp/third_party/asio.BUILD
create mode 100644 cpp/third_party/cpp_httplib.BUILD
create mode 100644 cpp/third_party/curl.BUILD
create mode 100644 cpp/third_party/filesystem.BUILD
create mode 100644 cpp/third_party/fmtlib.BUILD
create mode 100644 cpp/third_party/spdlog.BUILD
create mode 100644 cpp/tools/copyright.txt
create mode 100755 cpp/tools/coverage.sh
create mode 100755 cpp/tools/fix_copyright.py
create mode 100755 cpp/tools/format.sh
create mode 100644 cpp/tools/trouble_shooting.sh
create mode 100755 cpp/tools/use_clang.sh
create mode 100644 csharp/LICENSE
create mode 100644 csharp/NOTICE
create mode 100644 csharp/README.md
create mode 100644 csharp/examples/Program.cs
create mode 100644 csharp/examples/examples.csproj
create mode 100644 csharp/rocketmq-client-csharp/Address.cs
create mode 100644 csharp/rocketmq-client-csharp/AddressScheme.cs
create mode 100644 csharp/rocketmq-client-csharp/Broker.cs
create mode 100644 csharp/rocketmq-client-csharp/Client.cs
create mode 100644 csharp/rocketmq-client-csharp/ClientConfig.cs
create mode 100644 csharp/rocketmq-client-csharp/ClientLoggerInterceptor.cs
create mode 100644 csharp/rocketmq-client-csharp/ClientManager.cs
create mode 100644 csharp/rocketmq-client-csharp/ClientManagerFactory.cs
create mode 100644 csharp/rocketmq-client-csharp/ConfigFileCredentialsProvider.cs
create mode 100644 csharp/rocketmq-client-csharp/Credentials.cs
create mode 100644 csharp/rocketmq-client-csharp/IClient.cs
create mode 100644 csharp/rocketmq-client-csharp/IClientConfig.cs
create mode 100644 csharp/rocketmq-client-csharp/IClientManager.cs
create mode 100644 csharp/rocketmq-client-csharp/ICredentialsProvider.cs
create mode 100644 csharp/rocketmq-client-csharp/INameServerResolver.cs
create mode 100644 csharp/rocketmq-client-csharp/IProducer.cs
create mode 100644 csharp/rocketmq-client-csharp/IRpcClient.cs
create mode 100644 csharp/rocketmq-client-csharp/Message.cs
create mode 100644 csharp/rocketmq-client-csharp/MessageIdGenerator.cs
create mode 100644 csharp/rocketmq-client-csharp/MessageType.cs
create mode 100644 csharp/rocketmq-client-csharp/MetadataConstants.cs
create mode 100644 csharp/rocketmq-client-csharp/MqLogManager.cs
create mode 100644 csharp/rocketmq-client-csharp/Partition.cs
create mode 100644 csharp/rocketmq-client-csharp/Permission.cs
create mode 100644 csharp/rocketmq-client-csharp/Producer.cs
create mode 100644 csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/admin.proto
create mode 100644 csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/definition.proto
create mode 100644 csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/service.proto
create mode 100644 csharp/rocketmq-client-csharp/Protos/google/rpc/code.proto
create mode 100644 csharp/rocketmq-client-csharp/Protos/google/rpc/error_details.proto
create mode 100644 csharp/rocketmq-client-csharp/Protos/google/rpc/status.proto
create mode 100644 csharp/rocketmq-client-csharp/PublishLoadBalancer.cs
create mode 100644 csharp/rocketmq-client-csharp/RpcClient.cs
create mode 100644 csharp/rocketmq-client-csharp/SendResult.cs
create mode 100644 csharp/rocketmq-client-csharp/SendStatus.cs
create mode 100644 csharp/rocketmq-client-csharp/SequenceGenerator.cs
create mode 100644 csharp/rocketmq-client-csharp/ServiceAddress.cs
create mode 100644 csharp/rocketmq-client-csharp/Signature.cs
create mode 100644 csharp/rocketmq-client-csharp/StaticCredentialsProvider.cs
create mode 100644 csharp/rocketmq-client-csharp/StaticNameServerResolver.cs
create mode 100644 csharp/rocketmq-client-csharp/Topic.cs
create mode 100644 csharp/rocketmq-client-csharp/TopicRouteData.cs
create mode 100644 csharp/rocketmq-client-csharp/TopicRouteException.cs
create mode 100644 csharp/rocketmq-client-csharp/Utilities.cs
create mode 100644 csharp/rocketmq-client-csharp/rocketmq-client-csharp.csproj
create mode 100644 csharp/rocketmq-client-csharp/rocketmq-client-csharp.nlog
create mode 100644 csharp/rocketmq-client.sln
create mode 100644 csharp/tests/BrokerTest.cs
create mode 100644 csharp/tests/ClientConfigTest.cs
create mode 100644 csharp/tests/ClientManagerTest.cs
create mode 100644 csharp/tests/ConfigFileCredentialsProviderTest.cs
create mode 100644 csharp/tests/DateTimeTest.cs
create mode 100644 csharp/tests/MessageIdGeneratorTest.cs
create mode 100644 csharp/tests/MessageTest.cs
create mode 100644 csharp/tests/MqLogManagerTest.cs
create mode 100644 csharp/tests/ProducerTest.cs
create mode 100644 csharp/tests/RpcClientTest.cs
create mode 100644 csharp/tests/SendResultTest.cs
create mode 100644 csharp/tests/SequenceGeneratorTest.cs
create mode 100644 csharp/tests/SignatureTest.cs
create mode 100644 csharp/tests/StaticCredentialsProviderTest.cs
create mode 100644 csharp/tests/StaticNameServerResolverTest.cs
create mode 100644 csharp/tests/TopicTest.cs
create mode 100644 csharp/tests/UnitTest1.cs
create mode 100644 csharp/tests/tests.csproj