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 10:28:20 UTC

[rocketmq-clients] branch master updated (bcfd327 -> 05fa426)

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


 discard bcfd327  Merge pull request #2 from aaron-ai/pr
    omit cf29ae4  Fix GitHub Action working directory for C#
    omit 9bd57b4  Update .gitignore
    omit c46823c  Merge pull request #1 from aaron-ai/pr
    omit 014e0d8  Merge branch 'csharp' into clients
    omit 5576b51  Integret current repo with rocketmq clients
    omit 254e3a9  Merge branch 'main' into clients
    omit c233dee  Integret current repo with rocketmq clients
     new 68f6fd2  Integrate current repo with rocketmq clients
     new da9da5b  Merge branch 'main' into clients
     new 80d0981  Integrate current repo with rocketmq clients
     new ba4ab3d  Merge branch 'csharp' into clients
     new a2c6557  Update .gitignore
     new 05fa426  Fix GitHub Action working directory for C#

This update added new revisions after undoing existing revisions.
That is to say, some revisions that were in the old version of the
branch are not in the new version.  This situation occurs
when a user --force pushes a change and generates a repository
containing something like this:

 * -- * -- B -- O -- O -- O   (bcfd327)
            \
             N -- N -- N   refs/heads/master (05fa426)

You should already have received notification emails for all of the O
revisions, and so the following emails describe only the N revisions
from the common base, B.

Any revisions marked "omit" are not gone; other references still
refer to them.  Any revisions marked "discard" are gone forever.

The 6 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 | 39 +++++++++++++++++++++++++++++++++++++++
 1 file changed, 39 insertions(+)

[rocketmq-clients] 04/06: Merge branch 'csharp' into clients

Posted by aa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git

commit ba4ab3d8da48c2565f815c10277a1f655be582e5
Merge: da9da5b 80d0981
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Fri Jun 17 18:26:29 2022 +0800

    Merge branch 'csharp' into clients

 .github/workflows/main.yml                         |  23 +-
 .gitignore                                         |   6 +
 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 +
 72 files changed, 5347 insertions(+), 1 deletion(-)

diff --cc .github/workflows/main.yml
index 26c6d3b,4c41e55..cdea878
--- a/.github/workflows/main.yml
+++ b/.github/workflows/main.yml
@@@ -1,36 -1,18 +1,57 @@@
++<<<<<<< HEAD
 +# This is a basic workflow to help you get started with Actions
 +
 +name: CI
 +
 +# Controls when the workflow will run
 +on:
 +  # Triggers the workflow on push or pull request events but only for the master branch
 +  push:
 +    branches: [ main ]
 +  pull_request:
 +    branches: [ main ]
 +
 +  # Allows you to run this workflow manually from the Actions tab
 +  workflow_dispatch:
 +
 +# A workflow run is made up of one or more jobs that can run sequentially or in parallel
 +jobs:
 +  # This workflow contains a single job called "build"
 +  build:
 +    # The type of runner that the job will run on
 +    runs-on: ubuntu-latest
 +
 +    # Steps represent a sequence of tasks that will be executed as part of the job
 +    steps:
 +      # Checks-out your repository under $GITHUB_WORKSPACE, so your job can access it
 +      - uses: actions/checkout@v2
 +      
 +      - name: Setup Bazel
 +        run: |
 +          sudo apt-get -qq install npm
 +          sudo npm install -g @bazel/bazelisk
 +      - name: Use Bazel
 +        if: matrix.os != 'windows'
 +        run: bazel -h
 +      - name: Compile All Targets
-         run: bazel build //...
++        run: bazel build //...
++=======
+ name: CI
+ on: [push, pull_request]
+ jobs:
+   build:
+     runs-on: ubuntu-latest
+     steps:
+       - name: Checkout 
+         uses: actions/checkout@v2
+       - name: Setup dotnet
+         uses: actions/setup-dotnet@v1
+         with:
+           dotnet-version: | 
+             5.0.x
+             6.0.x
+       - name: Build artifacts
+         run: |
+           dotnet --version
 -          dotnet build
++          dotnet build
++>>>>>>> csharp

[rocketmq-clients] 05/06: Update .gitignore

Posted by aa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git

commit a2c6557413d4f4b9776db84b227a2a10f956a360
Author: Aaron Ai <aa...@apache.org>
AuthorDate: Fri Jun 17 17:44:06 2022 +0800

    Update .gitignore
---
 .gitignore | 30 +++++++++++++++++++++++++-----
 1 file changed, 25 insertions(+), 5 deletions(-)

diff --git a/.gitignore b/.gitignore
index 678b6cc..96db390 100644
--- a/.gitignore
+++ b/.gitignore
@@ -1,6 +1,26 @@
-bin
-obj
+# Intellij IDEA
+.idea/
+out/
+*.ipr
+*.iml
+*.iws
+
+# Eclipse
+.classpath
+.project
+.settings/
+.metadata/
+.factorypath
+
+# MacOS
+**/.DS_Store
+
+# Visual Studio Code
 .vscode/
-.idea
-*.user
-*DS_Store
\ No newline at end of file
+
+# Maven
+target/
+*.ser
+*.ec
+dependency-reduced-pom.xml
+.flattened-pom.xml

[rocketmq-clients] 02/06: Integrate current repo with rocketmq clients

Posted by aa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git

commit 80d098159af08509bc98143b2be1f82b42223cbb
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Fri Jun 17 16:45:36 2022 +0800

    Integrate current repo with rocketmq clients
---
 LICENSE => csharp/LICENSE                                                 | 0
 NOTICE => csharp/NOTICE                                                   | 0
 README.md => csharp/README.md                                             | 0
 {examples => csharp/examples}/Program.cs                                  | 0
 {examples => csharp/examples}/examples.csproj                             | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Address.cs      | 0
 .../rocketmq-client-csharp}/AddressScheme.cs                              | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Broker.cs       | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Client.cs       | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/ClientConfig.cs | 0
 .../rocketmq-client-csharp}/ClientLoggerInterceptor.cs                    | 0
 .../rocketmq-client-csharp}/ClientManager.cs                              | 0
 .../rocketmq-client-csharp}/ClientManagerFactory.cs                       | 0
 .../rocketmq-client-csharp}/ConfigFileCredentialsProvider.cs              | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Credentials.cs  | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/IClient.cs      | 0
 .../rocketmq-client-csharp}/IClientConfig.cs                              | 0
 .../rocketmq-client-csharp}/IClientManager.cs                             | 0
 .../rocketmq-client-csharp}/ICredentialsProvider.cs                       | 0
 .../rocketmq-client-csharp}/INameServerResolver.cs                        | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/IProducer.cs    | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/IRpcClient.cs   | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Message.cs      | 0
 .../rocketmq-client-csharp}/MessageIdGenerator.cs                         | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/MessageType.cs  | 0
 .../rocketmq-client-csharp}/MetadataConstants.cs                          | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/MqLogManager.cs | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Partition.cs    | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Permission.cs   | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Producer.cs     | 0
 .../rocketmq-client-csharp}/Protos/apache/rocketmq/v1/admin.proto         | 0
 .../rocketmq-client-csharp}/Protos/apache/rocketmq/v1/definition.proto    | 0
 .../rocketmq-client-csharp}/Protos/apache/rocketmq/v1/service.proto       | 0
 .../rocketmq-client-csharp}/Protos/google/rpc/code.proto                  | 0
 .../rocketmq-client-csharp}/Protos/google/rpc/error_details.proto         | 0
 .../rocketmq-client-csharp}/Protos/google/rpc/status.proto                | 0
 .../rocketmq-client-csharp}/PublishLoadBalancer.cs                        | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/RpcClient.cs    | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/SendResult.cs   | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/SendStatus.cs   | 0
 .../rocketmq-client-csharp}/SequenceGenerator.cs                          | 0
 .../rocketmq-client-csharp}/ServiceAddress.cs                             | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Signature.cs    | 0
 .../rocketmq-client-csharp}/StaticCredentialsProvider.cs                  | 0
 .../rocketmq-client-csharp}/StaticNameServerResolver.cs                   | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Topic.cs        | 0
 .../rocketmq-client-csharp}/TopicRouteData.cs                             | 0
 .../rocketmq-client-csharp}/TopicRouteException.cs                        | 0
 {rocketmq-client-csharp => csharp/rocketmq-client-csharp}/Utilities.cs    | 0
 .../rocketmq-client-csharp}/rocketmq-client-csharp.csproj                 | 0
 .../rocketmq-client-csharp}/rocketmq-client-csharp.nlog                   | 0
 rocketmq-client.sln => csharp/rocketmq-client.sln                         | 0
 {tests => csharp/tests}/BrokerTest.cs                                     | 0
 {tests => csharp/tests}/ClientConfigTest.cs                               | 0
 {tests => csharp/tests}/ClientManagerTest.cs                              | 0
 {tests => csharp/tests}/ConfigFileCredentialsProviderTest.cs              | 0
 {tests => csharp/tests}/DateTimeTest.cs                                   | 0
 {tests => csharp/tests}/MessageIdGeneratorTest.cs                         | 0
 {tests => csharp/tests}/MessageTest.cs                                    | 0
 {tests => csharp/tests}/MqLogManagerTest.cs                               | 0
 {tests => csharp/tests}/ProducerTest.cs                                   | 0
 {tests => csharp/tests}/RpcClientTest.cs                                  | 0
 {tests => csharp/tests}/SendResultTest.cs                                 | 0
 {tests => csharp/tests}/SequenceGeneratorTest.cs                          | 0
 {tests => csharp/tests}/SignatureTest.cs                                  | 0
 {tests => csharp/tests}/StaticCredentialsProviderTest.cs                  | 0
 {tests => csharp/tests}/StaticNameServerResolverTest.cs                   | 0
 {tests => csharp/tests}/TopicTest.cs                                      | 0
 {tests => csharp/tests}/UnitTest1.cs                                      | 0
 {tests => csharp/tests}/tests.csproj                                      | 0
 70 files changed, 0 insertions(+), 0 deletions(-)

diff --git a/LICENSE b/csharp/LICENSE
similarity index 100%
rename from LICENSE
rename to csharp/LICENSE
diff --git a/NOTICE b/csharp/NOTICE
similarity index 100%
rename from NOTICE
rename to csharp/NOTICE
diff --git a/README.md b/csharp/README.md
similarity index 100%
rename from README.md
rename to csharp/README.md
diff --git a/examples/Program.cs b/csharp/examples/Program.cs
similarity index 100%
rename from examples/Program.cs
rename to csharp/examples/Program.cs
diff --git a/examples/examples.csproj b/csharp/examples/examples.csproj
similarity index 100%
rename from examples/examples.csproj
rename to csharp/examples/examples.csproj
diff --git a/rocketmq-client-csharp/Address.cs b/csharp/rocketmq-client-csharp/Address.cs
similarity index 100%
rename from rocketmq-client-csharp/Address.cs
rename to csharp/rocketmq-client-csharp/Address.cs
diff --git a/rocketmq-client-csharp/AddressScheme.cs b/csharp/rocketmq-client-csharp/AddressScheme.cs
similarity index 100%
rename from rocketmq-client-csharp/AddressScheme.cs
rename to csharp/rocketmq-client-csharp/AddressScheme.cs
diff --git a/rocketmq-client-csharp/Broker.cs b/csharp/rocketmq-client-csharp/Broker.cs
similarity index 100%
rename from rocketmq-client-csharp/Broker.cs
rename to csharp/rocketmq-client-csharp/Broker.cs
diff --git a/rocketmq-client-csharp/Client.cs b/csharp/rocketmq-client-csharp/Client.cs
similarity index 100%
rename from rocketmq-client-csharp/Client.cs
rename to csharp/rocketmq-client-csharp/Client.cs
diff --git a/rocketmq-client-csharp/ClientConfig.cs b/csharp/rocketmq-client-csharp/ClientConfig.cs
similarity index 100%
rename from rocketmq-client-csharp/ClientConfig.cs
rename to csharp/rocketmq-client-csharp/ClientConfig.cs
diff --git a/rocketmq-client-csharp/ClientLoggerInterceptor.cs b/csharp/rocketmq-client-csharp/ClientLoggerInterceptor.cs
similarity index 100%
rename from rocketmq-client-csharp/ClientLoggerInterceptor.cs
rename to csharp/rocketmq-client-csharp/ClientLoggerInterceptor.cs
diff --git a/rocketmq-client-csharp/ClientManager.cs b/csharp/rocketmq-client-csharp/ClientManager.cs
similarity index 100%
rename from rocketmq-client-csharp/ClientManager.cs
rename to csharp/rocketmq-client-csharp/ClientManager.cs
diff --git a/rocketmq-client-csharp/ClientManagerFactory.cs b/csharp/rocketmq-client-csharp/ClientManagerFactory.cs
similarity index 100%
rename from rocketmq-client-csharp/ClientManagerFactory.cs
rename to csharp/rocketmq-client-csharp/ClientManagerFactory.cs
diff --git a/rocketmq-client-csharp/ConfigFileCredentialsProvider.cs b/csharp/rocketmq-client-csharp/ConfigFileCredentialsProvider.cs
similarity index 100%
rename from rocketmq-client-csharp/ConfigFileCredentialsProvider.cs
rename to csharp/rocketmq-client-csharp/ConfigFileCredentialsProvider.cs
diff --git a/rocketmq-client-csharp/Credentials.cs b/csharp/rocketmq-client-csharp/Credentials.cs
similarity index 100%
rename from rocketmq-client-csharp/Credentials.cs
rename to csharp/rocketmq-client-csharp/Credentials.cs
diff --git a/rocketmq-client-csharp/IClient.cs b/csharp/rocketmq-client-csharp/IClient.cs
similarity index 100%
rename from rocketmq-client-csharp/IClient.cs
rename to csharp/rocketmq-client-csharp/IClient.cs
diff --git a/rocketmq-client-csharp/IClientConfig.cs b/csharp/rocketmq-client-csharp/IClientConfig.cs
similarity index 100%
rename from rocketmq-client-csharp/IClientConfig.cs
rename to csharp/rocketmq-client-csharp/IClientConfig.cs
diff --git a/rocketmq-client-csharp/IClientManager.cs b/csharp/rocketmq-client-csharp/IClientManager.cs
similarity index 100%
rename from rocketmq-client-csharp/IClientManager.cs
rename to csharp/rocketmq-client-csharp/IClientManager.cs
diff --git a/rocketmq-client-csharp/ICredentialsProvider.cs b/csharp/rocketmq-client-csharp/ICredentialsProvider.cs
similarity index 100%
rename from rocketmq-client-csharp/ICredentialsProvider.cs
rename to csharp/rocketmq-client-csharp/ICredentialsProvider.cs
diff --git a/rocketmq-client-csharp/INameServerResolver.cs b/csharp/rocketmq-client-csharp/INameServerResolver.cs
similarity index 100%
rename from rocketmq-client-csharp/INameServerResolver.cs
rename to csharp/rocketmq-client-csharp/INameServerResolver.cs
diff --git a/rocketmq-client-csharp/IProducer.cs b/csharp/rocketmq-client-csharp/IProducer.cs
similarity index 100%
rename from rocketmq-client-csharp/IProducer.cs
rename to csharp/rocketmq-client-csharp/IProducer.cs
diff --git a/rocketmq-client-csharp/IRpcClient.cs b/csharp/rocketmq-client-csharp/IRpcClient.cs
similarity index 100%
rename from rocketmq-client-csharp/IRpcClient.cs
rename to csharp/rocketmq-client-csharp/IRpcClient.cs
diff --git a/rocketmq-client-csharp/Message.cs b/csharp/rocketmq-client-csharp/Message.cs
similarity index 100%
rename from rocketmq-client-csharp/Message.cs
rename to csharp/rocketmq-client-csharp/Message.cs
diff --git a/rocketmq-client-csharp/MessageIdGenerator.cs b/csharp/rocketmq-client-csharp/MessageIdGenerator.cs
similarity index 100%
rename from rocketmq-client-csharp/MessageIdGenerator.cs
rename to csharp/rocketmq-client-csharp/MessageIdGenerator.cs
diff --git a/rocketmq-client-csharp/MessageType.cs b/csharp/rocketmq-client-csharp/MessageType.cs
similarity index 100%
rename from rocketmq-client-csharp/MessageType.cs
rename to csharp/rocketmq-client-csharp/MessageType.cs
diff --git a/rocketmq-client-csharp/MetadataConstants.cs b/csharp/rocketmq-client-csharp/MetadataConstants.cs
similarity index 100%
rename from rocketmq-client-csharp/MetadataConstants.cs
rename to csharp/rocketmq-client-csharp/MetadataConstants.cs
diff --git a/rocketmq-client-csharp/MqLogManager.cs b/csharp/rocketmq-client-csharp/MqLogManager.cs
similarity index 100%
rename from rocketmq-client-csharp/MqLogManager.cs
rename to csharp/rocketmq-client-csharp/MqLogManager.cs
diff --git a/rocketmq-client-csharp/Partition.cs b/csharp/rocketmq-client-csharp/Partition.cs
similarity index 100%
rename from rocketmq-client-csharp/Partition.cs
rename to csharp/rocketmq-client-csharp/Partition.cs
diff --git a/rocketmq-client-csharp/Permission.cs b/csharp/rocketmq-client-csharp/Permission.cs
similarity index 100%
rename from rocketmq-client-csharp/Permission.cs
rename to csharp/rocketmq-client-csharp/Permission.cs
diff --git a/rocketmq-client-csharp/Producer.cs b/csharp/rocketmq-client-csharp/Producer.cs
similarity index 100%
rename from rocketmq-client-csharp/Producer.cs
rename to csharp/rocketmq-client-csharp/Producer.cs
diff --git a/rocketmq-client-csharp/Protos/apache/rocketmq/v1/admin.proto b/csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/admin.proto
similarity index 100%
rename from rocketmq-client-csharp/Protos/apache/rocketmq/v1/admin.proto
rename to csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/admin.proto
diff --git a/rocketmq-client-csharp/Protos/apache/rocketmq/v1/definition.proto b/csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/definition.proto
similarity index 100%
rename from rocketmq-client-csharp/Protos/apache/rocketmq/v1/definition.proto
rename to csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/definition.proto
diff --git a/rocketmq-client-csharp/Protos/apache/rocketmq/v1/service.proto b/csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/service.proto
similarity index 100%
rename from rocketmq-client-csharp/Protos/apache/rocketmq/v1/service.proto
rename to csharp/rocketmq-client-csharp/Protos/apache/rocketmq/v1/service.proto
diff --git a/rocketmq-client-csharp/Protos/google/rpc/code.proto b/csharp/rocketmq-client-csharp/Protos/google/rpc/code.proto
similarity index 100%
rename from rocketmq-client-csharp/Protos/google/rpc/code.proto
rename to csharp/rocketmq-client-csharp/Protos/google/rpc/code.proto
diff --git a/rocketmq-client-csharp/Protos/google/rpc/error_details.proto b/csharp/rocketmq-client-csharp/Protos/google/rpc/error_details.proto
similarity index 100%
rename from rocketmq-client-csharp/Protos/google/rpc/error_details.proto
rename to csharp/rocketmq-client-csharp/Protos/google/rpc/error_details.proto
diff --git a/rocketmq-client-csharp/Protos/google/rpc/status.proto b/csharp/rocketmq-client-csharp/Protos/google/rpc/status.proto
similarity index 100%
rename from rocketmq-client-csharp/Protos/google/rpc/status.proto
rename to csharp/rocketmq-client-csharp/Protos/google/rpc/status.proto
diff --git a/rocketmq-client-csharp/PublishLoadBalancer.cs b/csharp/rocketmq-client-csharp/PublishLoadBalancer.cs
similarity index 100%
rename from rocketmq-client-csharp/PublishLoadBalancer.cs
rename to csharp/rocketmq-client-csharp/PublishLoadBalancer.cs
diff --git a/rocketmq-client-csharp/RpcClient.cs b/csharp/rocketmq-client-csharp/RpcClient.cs
similarity index 100%
rename from rocketmq-client-csharp/RpcClient.cs
rename to csharp/rocketmq-client-csharp/RpcClient.cs
diff --git a/rocketmq-client-csharp/SendResult.cs b/csharp/rocketmq-client-csharp/SendResult.cs
similarity index 100%
rename from rocketmq-client-csharp/SendResult.cs
rename to csharp/rocketmq-client-csharp/SendResult.cs
diff --git a/rocketmq-client-csharp/SendStatus.cs b/csharp/rocketmq-client-csharp/SendStatus.cs
similarity index 100%
rename from rocketmq-client-csharp/SendStatus.cs
rename to csharp/rocketmq-client-csharp/SendStatus.cs
diff --git a/rocketmq-client-csharp/SequenceGenerator.cs b/csharp/rocketmq-client-csharp/SequenceGenerator.cs
similarity index 100%
rename from rocketmq-client-csharp/SequenceGenerator.cs
rename to csharp/rocketmq-client-csharp/SequenceGenerator.cs
diff --git a/rocketmq-client-csharp/ServiceAddress.cs b/csharp/rocketmq-client-csharp/ServiceAddress.cs
similarity index 100%
rename from rocketmq-client-csharp/ServiceAddress.cs
rename to csharp/rocketmq-client-csharp/ServiceAddress.cs
diff --git a/rocketmq-client-csharp/Signature.cs b/csharp/rocketmq-client-csharp/Signature.cs
similarity index 100%
rename from rocketmq-client-csharp/Signature.cs
rename to csharp/rocketmq-client-csharp/Signature.cs
diff --git a/rocketmq-client-csharp/StaticCredentialsProvider.cs b/csharp/rocketmq-client-csharp/StaticCredentialsProvider.cs
similarity index 100%
rename from rocketmq-client-csharp/StaticCredentialsProvider.cs
rename to csharp/rocketmq-client-csharp/StaticCredentialsProvider.cs
diff --git a/rocketmq-client-csharp/StaticNameServerResolver.cs b/csharp/rocketmq-client-csharp/StaticNameServerResolver.cs
similarity index 100%
rename from rocketmq-client-csharp/StaticNameServerResolver.cs
rename to csharp/rocketmq-client-csharp/StaticNameServerResolver.cs
diff --git a/rocketmq-client-csharp/Topic.cs b/csharp/rocketmq-client-csharp/Topic.cs
similarity index 100%
rename from rocketmq-client-csharp/Topic.cs
rename to csharp/rocketmq-client-csharp/Topic.cs
diff --git a/rocketmq-client-csharp/TopicRouteData.cs b/csharp/rocketmq-client-csharp/TopicRouteData.cs
similarity index 100%
rename from rocketmq-client-csharp/TopicRouteData.cs
rename to csharp/rocketmq-client-csharp/TopicRouteData.cs
diff --git a/rocketmq-client-csharp/TopicRouteException.cs b/csharp/rocketmq-client-csharp/TopicRouteException.cs
similarity index 100%
rename from rocketmq-client-csharp/TopicRouteException.cs
rename to csharp/rocketmq-client-csharp/TopicRouteException.cs
diff --git a/rocketmq-client-csharp/Utilities.cs b/csharp/rocketmq-client-csharp/Utilities.cs
similarity index 100%
rename from rocketmq-client-csharp/Utilities.cs
rename to csharp/rocketmq-client-csharp/Utilities.cs
diff --git a/rocketmq-client-csharp/rocketmq-client-csharp.csproj b/csharp/rocketmq-client-csharp/rocketmq-client-csharp.csproj
similarity index 100%
rename from rocketmq-client-csharp/rocketmq-client-csharp.csproj
rename to csharp/rocketmq-client-csharp/rocketmq-client-csharp.csproj
diff --git a/rocketmq-client-csharp/rocketmq-client-csharp.nlog b/csharp/rocketmq-client-csharp/rocketmq-client-csharp.nlog
similarity index 100%
rename from rocketmq-client-csharp/rocketmq-client-csharp.nlog
rename to csharp/rocketmq-client-csharp/rocketmq-client-csharp.nlog
diff --git a/rocketmq-client.sln b/csharp/rocketmq-client.sln
similarity index 100%
rename from rocketmq-client.sln
rename to csharp/rocketmq-client.sln
diff --git a/tests/BrokerTest.cs b/csharp/tests/BrokerTest.cs
similarity index 100%
rename from tests/BrokerTest.cs
rename to csharp/tests/BrokerTest.cs
diff --git a/tests/ClientConfigTest.cs b/csharp/tests/ClientConfigTest.cs
similarity index 100%
rename from tests/ClientConfigTest.cs
rename to csharp/tests/ClientConfigTest.cs
diff --git a/tests/ClientManagerTest.cs b/csharp/tests/ClientManagerTest.cs
similarity index 100%
rename from tests/ClientManagerTest.cs
rename to csharp/tests/ClientManagerTest.cs
diff --git a/tests/ConfigFileCredentialsProviderTest.cs b/csharp/tests/ConfigFileCredentialsProviderTest.cs
similarity index 100%
rename from tests/ConfigFileCredentialsProviderTest.cs
rename to csharp/tests/ConfigFileCredentialsProviderTest.cs
diff --git a/tests/DateTimeTest.cs b/csharp/tests/DateTimeTest.cs
similarity index 100%
rename from tests/DateTimeTest.cs
rename to csharp/tests/DateTimeTest.cs
diff --git a/tests/MessageIdGeneratorTest.cs b/csharp/tests/MessageIdGeneratorTest.cs
similarity index 100%
rename from tests/MessageIdGeneratorTest.cs
rename to csharp/tests/MessageIdGeneratorTest.cs
diff --git a/tests/MessageTest.cs b/csharp/tests/MessageTest.cs
similarity index 100%
rename from tests/MessageTest.cs
rename to csharp/tests/MessageTest.cs
diff --git a/tests/MqLogManagerTest.cs b/csharp/tests/MqLogManagerTest.cs
similarity index 100%
rename from tests/MqLogManagerTest.cs
rename to csharp/tests/MqLogManagerTest.cs
diff --git a/tests/ProducerTest.cs b/csharp/tests/ProducerTest.cs
similarity index 100%
rename from tests/ProducerTest.cs
rename to csharp/tests/ProducerTest.cs
diff --git a/tests/RpcClientTest.cs b/csharp/tests/RpcClientTest.cs
similarity index 100%
rename from tests/RpcClientTest.cs
rename to csharp/tests/RpcClientTest.cs
diff --git a/tests/SendResultTest.cs b/csharp/tests/SendResultTest.cs
similarity index 100%
rename from tests/SendResultTest.cs
rename to csharp/tests/SendResultTest.cs
diff --git a/tests/SequenceGeneratorTest.cs b/csharp/tests/SequenceGeneratorTest.cs
similarity index 100%
rename from tests/SequenceGeneratorTest.cs
rename to csharp/tests/SequenceGeneratorTest.cs
diff --git a/tests/SignatureTest.cs b/csharp/tests/SignatureTest.cs
similarity index 100%
rename from tests/SignatureTest.cs
rename to csharp/tests/SignatureTest.cs
diff --git a/tests/StaticCredentialsProviderTest.cs b/csharp/tests/StaticCredentialsProviderTest.cs
similarity index 100%
rename from tests/StaticCredentialsProviderTest.cs
rename to csharp/tests/StaticCredentialsProviderTest.cs
diff --git a/tests/StaticNameServerResolverTest.cs b/csharp/tests/StaticNameServerResolverTest.cs
similarity index 100%
rename from tests/StaticNameServerResolverTest.cs
rename to csharp/tests/StaticNameServerResolverTest.cs
diff --git a/tests/TopicTest.cs b/csharp/tests/TopicTest.cs
similarity index 100%
rename from tests/TopicTest.cs
rename to csharp/tests/TopicTest.cs
diff --git a/tests/UnitTest1.cs b/csharp/tests/UnitTest1.cs
similarity index 100%
rename from tests/UnitTest1.cs
rename to csharp/tests/UnitTest1.cs
diff --git a/tests/tests.csproj b/csharp/tests/tests.csproj
similarity index 100%
rename from tests/tests.csproj
rename to csharp/tests/tests.csproj

[rocketmq-clients] 06/06: Fix GitHub Action working directory for C#

Posted by aa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git

commit 05fa426e13b4c78a7ad31524d1e99750dfb788c6
Author: Aaron Ai <ya...@gmail.com>
AuthorDate: Fri Jun 17 17:51:07 2022 +0800

    Fix GitHub Action working directory for C#
---
 .github/workflows/main.yml | 1 +
 1 file changed, 1 insertion(+)

diff --git a/.github/workflows/main.yml b/.github/workflows/main.yml
index cdea878..aeb0b93 100644
--- a/.github/workflows/main.yml
+++ b/.github/workflows/main.yml
@@ -51,6 +51,7 @@ jobs:
             5.0.x
             6.0.x
       - name: Build artifacts
+        working-directory: ./csharp
         run: |
           dotnet --version
           dotnet build

[rocketmq-clients] 01/06: Integrate current repo with rocketmq clients

Posted by aa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git

commit 68f6fd2bd39a3cbbd3a4455b476d4b53702f31a8
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Fri Jun 17 16:43:02 2022 +0800

    Integrate current repo with rocketmq clients
---
 .bazelignore => cpp/.bazelignore                            |   0
 .bazelrc => cpp/.bazelrc                                    |   0
 .bazelversion => cpp/.bazelversion                          |   0
 .clang-format => cpp/.clang-format                          |   0
 .clang-tidy => cpp/.clang-tidy                              |   0
 .gitignore => cpp/.gitignore                                |   0
 .travis.yml => cpp/.travis.yml                              |   0
 BUILD.bazel => cpp/BUILD.bazel                              |   0
 LICENSE => cpp/LICENSE                                      |   0
 README.md => cpp/README.md                                  |   0
 WORKSPACE => cpp/WORKSPACE                                  |   0
 {api => cpp/api}/BUILD.bazel                                |   0
 {api => cpp/api}/rocketmq/AdminServer.h                     |   0
 {api => cpp/api}/rocketmq/BackoffPolicy.h                   |   0
 {api => cpp/api}/rocketmq/Configuration.h                   |   0
 {api => cpp/api}/rocketmq/ConfigurationDefaults.h           |   0
 {api => cpp/api}/rocketmq/ConsumeResult.h                   |   0
 {api => cpp/api}/rocketmq/Credentials.h                     |   0
 {api => cpp/api}/rocketmq/CredentialsProvider.h             |   0
 {api => cpp/api}/rocketmq/ErrorCategory.h                   |   0
 {api => cpp/api}/rocketmq/ErrorCode.h                       |   0
 {api => cpp/api}/rocketmq/Executor.h                        |   0
 {api => cpp/api}/rocketmq/ExpressionType.h                  |   0
 {api => cpp/api}/rocketmq/FilterExpression.h                |   0
 {api => cpp/api}/rocketmq/Logger.h                          |   0
 {api => cpp/api}/rocketmq/MQClientException.h               |   0
 {api => cpp/api}/rocketmq/Message.h                         |   0
 {api => cpp/api}/rocketmq/MessageListener.h                 |   0
 {api => cpp/api}/rocketmq/Producer.h                        |   0
 {api => cpp/api}/rocketmq/PushConsumer.h                    |   0
 {api => cpp/api}/rocketmq/RocketMQ.h                        |   0
 {api => cpp/api}/rocketmq/SendCallback.h                    |   0
 {api => cpp/api}/rocketmq/SendReceipt.h                     |   0
 {api => cpp/api}/rocketmq/SimpleConsumer.h                  |   0
 {api => cpp/api}/rocketmq/State.h                           |   0
 {api => cpp/api}/rocketmq/Tracing.h                         |   0
 {api => cpp/api}/rocketmq/Transaction.h                     |   0
 {api => cpp/api}/rocketmq/TransactionChecker.h              |   0
 {api => cpp/api}/rocketmq/TransactionState.h                |   0
 {bazel => cpp/bazel}/BUILD.bazel                            |   0
 {bazel => cpp/bazel}/curl.bzl                               |   0
 {bazel => cpp/bazel}/rocketmq_deps.bzl                      |   0
 {ci => cpp/ci}/build.sh                                     |   0
 {docs => cpp/docs}/assets/BasicMode.png                     | Bin
 {docs => cpp/docs}/assets/class_diagram.png                 | Bin
 {docs => cpp/docs}/gtest.md                                 |   0
 {docs => cpp/docs}/test_coverage.md                         |   0
 {examples => cpp/examples}/BUILD.bazel                      |   0
 {examples => cpp/examples}/BenchmarkPushConsumer.cpp        |   0
 {examples => cpp/examples}/ExampleAsyncProducer.cpp         |   0
 {examples => cpp/examples}/ExampleFifoProducer.cpp          |   0
 {examples => cpp/examples}/ExampleFifoPushConsumer.cpp      |   0
 {examples => cpp/examples}/ExampleProducer.cpp              |   0
 {examples => cpp/examples}/ExamplePushConsumer.cpp          |   0
 {examples => cpp/examples}/ExampleSimpleConsumer.cpp        |   0
 {examples => cpp/examples}/ExampleTransactionProducer.cpp   |   0
 .../examples}/PushConsumerWithCustomExecutor.cpp            |   0
 {examples => cpp/examples}/PushConsumerWithThrottle.cpp     |   0
 {examples => cpp/examples}/SqlConsumer.cpp                  |   0
 {examples => cpp/examples}/SqlProducer.cpp                  |   0
 {proto => cpp/proto}/BUILD.bazel                            |   0
 {proto => cpp/proto}/apache/rocketmq/v2/admin.proto         |   0
 {proto => cpp/proto}/apache/rocketmq/v2/definition.proto    |   0
 {proto => cpp/proto}/apache/rocketmq/v2/service.proto       |   0
 {src => cpp/src}/main/cpp/admin/AdminClient.cpp             |   0
 {src => cpp/src}/main/cpp/admin/AdminFacade.cpp             |   0
 {src => cpp/src}/main/cpp/admin/AdminServerImpl.cpp         |   0
 {src => cpp/src}/main/cpp/admin/AdminServiceImpl.cpp        |   0
 {src => cpp/src}/main/cpp/admin/BUILD.bazel                 |   0
 {src => cpp/src}/main/cpp/admin/include/AdminClient.h       |   0
 {src => cpp/src}/main/cpp/admin/include/AdminServerImpl.h   |   0
 {src => cpp/src}/main/cpp/admin/include/AdminServiceImpl.h  |   0
 {src => cpp/src}/main/cpp/admin/include/ServerCall.h        |   0
 {src => cpp/src}/main/cpp/base/BUILD.bazel                  |   0
 {src => cpp/src}/main/cpp/base/Configuration.cpp            |   0
 {src => cpp/src}/main/cpp/base/ConfigurationDefaults.cpp    |   0
 {src => cpp/src}/main/cpp/base/CredentialsProvider.cpp      |   0
 {src => cpp/src}/main/cpp/base/ErrorCategory.cpp            |   0
 {src => cpp/src}/main/cpp/base/ErrorCode.cpp                |   0
 {src => cpp/src}/main/cpp/base/FilterExpression.cpp         |   0
 {src => cpp/src}/main/cpp/base/HostInfo.cpp                 |   0
 {src => cpp/src}/main/cpp/base/HttpClientImpl.cpp           |   0
 {src => cpp/src}/main/cpp/base/Message.cpp                  |   0
 {src => cpp/src}/main/cpp/base/MessageExt.cpp               |   0
 {src => cpp/src}/main/cpp/base/MetadataConstants.cpp        |   0
 {src => cpp/src}/main/cpp/base/MixAll.cpp                   |   0
 {src => cpp/src}/main/cpp/base/Protocol.cpp                 |   0
 {src => cpp/src}/main/cpp/base/RateLimiter.cpp              |   0
 {src => cpp/src}/main/cpp/base/ThreadPoolImpl.cpp           |   0
 {src => cpp/src}/main/cpp/base/TopAddressing.cpp            |   0
 {src => cpp/src}/main/cpp/base/Tracing.cpp                  |   0
 {src => cpp/src}/main/cpp/base/UniqueIdGenerator.cpp        |   0
 {src => cpp/src}/main/cpp/base/UtilAll.cpp                  |   0
 {src => cpp/src}/main/cpp/base/include/Histogram.h          |   0
 {src => cpp/src}/main/cpp/base/include/HostInfo.h           |   0
 {src => cpp/src}/main/cpp/base/include/HttpClient.h         |   0
 {src => cpp/src}/main/cpp/base/include/HttpClientImpl.h     |   0
 {src => cpp/src}/main/cpp/base/include/InvocationContext.h  |   0
 {src => cpp/src}/main/cpp/base/include/MessageExt.h         |   0
 {src => cpp/src}/main/cpp/base/include/MetadataConstants.h  |   0
 {src => cpp/src}/main/cpp/base/include/MixAll.h             |   0
 {src => cpp/src}/main/cpp/base/include/Protocol.h           |   0
 {src => cpp/src}/main/cpp/base/include/RateLimiter.h        |   0
 {src => cpp/src}/main/cpp/base/include/RetryPolicy.h        |   0
 .../src}/main/cpp/base/include/StsCredentialsProviderImpl.h |   0
 {src => cpp/src}/main/cpp/base/include/SubscriptionEntry.h  |   0
 {src => cpp/src}/main/cpp/base/include/ThreadPool.h         |   0
 {src => cpp/src}/main/cpp/base/include/ThreadPoolImpl.h     |   0
 {src => cpp/src}/main/cpp/base/include/TopAddressing.h      |   0
 {src => cpp/src}/main/cpp/base/include/UniqueIdGenerator.h  |   0
 {src => cpp/src}/main/cpp/base/include/UtilAll.h            |   0
 {src => cpp/src}/main/cpp/base/mocks/BUILD.bazel            |   0
 .../src}/main/cpp/base/mocks/include/HttpClientMock.h       |   0
 .../src}/main/cpp/base/mocks/include/MessageListenerMock.h  |   0
 {src => cpp/src}/main/cpp/base/tests/AssignmentTest.cpp     |   0
 {src => cpp/src}/main/cpp/base/tests/BUILD.bazel            |   0
 {src => cpp/src}/main/cpp/base/tests/ConfigurationTest.cpp  |   0
 {src => cpp/src}/main/cpp/base/tests/MessageBuilderTest.cpp |   0
 {src => cpp/src}/main/cpp/base/tests/MessageQueueTest.cpp   |   0
 {src => cpp/src}/main/cpp/base/tests/MixAllTest.cpp         |   0
 {src => cpp/src}/main/cpp/base/tests/RetryPolicyTest.cpp    |   0
 {src => cpp/src}/main/cpp/client/BUILD.bazel                |   0
 {src => cpp/src}/main/cpp/client/ClientManagerFactory.cpp   |   0
 {src => cpp/src}/main/cpp/client/ClientManagerImpl.cpp      |   0
 {src => cpp/src}/main/cpp/client/LogInterceptor.cpp         |   0
 {src => cpp/src}/main/cpp/client/LogInterceptorFactory.cpp  |   0
 .../src}/main/cpp/client/ReceiveMessageStreamReader.cpp     |   0
 {src => cpp/src}/main/cpp/client/RpcClientImpl.cpp          |   0
 {src => cpp/src}/main/cpp/client/SessionImpl.cpp            |   0
 {src => cpp/src}/main/cpp/client/Signature.cpp              |   0
 {src => cpp/src}/main/cpp/client/TelemetryBidiReactor.cpp   |   0
 {src => cpp/src}/main/cpp/client/TlsHelper.cpp              |   0
 {src => cpp/src}/main/cpp/client/TopicAssignmentInfo.cpp    |   0
 {src => cpp/src}/main/cpp/client/include/Client.h           |   0
 {src => cpp/src}/main/cpp/client/include/ClientConfig.h     |   0
 {src => cpp/src}/main/cpp/client/include/ClientManager.h    |   0
 .../src}/main/cpp/client/include/ClientManagerFactory.h     |   0
 .../src}/main/cpp/client/include/ClientManagerImpl.h        |   0
 .../src}/main/cpp/client/include/ConsumeMessageType.h       |   0
 .../src}/main/cpp/client/include/HeartbeatDataCallback.h    |   0
 .../main/cpp/client/include/InsecureCertificateVerifier.h   |   0
 .../src}/main/cpp/client/include/InterceptorContinuation.h  |   0
 {src => cpp/src}/main/cpp/client/include/LogInterceptor.h   |   0
 .../src}/main/cpp/client/include/LogInterceptorFactory.h    |   0
 {src => cpp/src}/main/cpp/client/include/Metadata.h         |   0
 .../src}/main/cpp/client/include/OpenSSLCompatible.h        |   0
 .../src}/main/cpp/client/include/ReceiveMessageCallback.h   |   0
 .../src}/main/cpp/client/include/ReceiveMessageContext.h    |   0
 .../src}/main/cpp/client/include/ReceiveMessageResult.h     |   0
 .../main/cpp/client/include/ReceiveMessageStreamReader.h    |   0
 {src => cpp/src}/main/cpp/client/include/RpcClient.h        |   0
 {src => cpp/src}/main/cpp/client/include/RpcClientImpl.h    |   0
 .../src}/main/cpp/client/include/SendMessageContext.h       |   0
 {src => cpp/src}/main/cpp/client/include/Session.h          |   0
 {src => cpp/src}/main/cpp/client/include/SessionImpl.h      |   0
 {src => cpp/src}/main/cpp/client/include/Signature.h        |   0
 .../src}/main/cpp/client/include/TelemetryBidiReactor.h     |   0
 {src => cpp/src}/main/cpp/client/include/TlsHelper.h        |   0
 {src => cpp/src}/main/cpp/client/include/Topic.h            |   0
 .../src}/main/cpp/client/include/TopicAssignmentInfo.h      |   0
 .../src}/main/cpp/client/include/TopicRouteChangeCallback.h |   0
 {src => cpp/src}/main/cpp/client/include/TopicRouteData.h   |   0
 {src => cpp/src}/main/cpp/client/mocks/BUILD.bazel          |   0
 .../src}/main/cpp/client/mocks/include/ClientManagerMock.h  |   0
 {src => cpp/src}/main/cpp/client/mocks/include/ClientMock.h |   0
 .../cpp/client/mocks/include/ReceiveMessageCallbackMock.h   |   0
 .../src}/main/cpp/client/mocks/include/RpcClientMock.h      |   0
 {src => cpp/src}/main/cpp/concurrent/BUILD.bazel            |   0
 {src => cpp/src}/main/cpp/concurrent/CountdownLatch.cpp     |   0
 .../src}/main/cpp/concurrent/include/CountdownLatch.h       |   0
 {src => cpp/src}/main/cpp/log/BUILD.bazel                   |   0
 {src => cpp/src}/main/cpp/log/LoggerImpl.cpp                |   0
 {src => cpp/src}/main/cpp/log/include/LoggerImpl.h          |   0
 {src => cpp/src}/main/cpp/remoting/BUILD.bazel              |   0
 {src => cpp/src}/main/cpp/remoting/BrokerData.cpp           |   0
 .../src}/main/cpp/remoting/QueryRouteRequestHeader.cpp      |   0
 {src => cpp/src}/main/cpp/remoting/QueueData.cpp            |   0
 {src => cpp/src}/main/cpp/remoting/RemotingCommand.cpp      |   0
 {src => cpp/src}/main/cpp/remoting/TopicRouteData.cpp       |   0
 {src => cpp/src}/main/cpp/remoting/include/BrokerData.h     |   0
 .../src}/main/cpp/remoting/include/CommandCustomHeader.h    |   0
 {src => cpp/src}/main/cpp/remoting/include/LanguageCode.h   |   0
 .../main/cpp/remoting/include/QueryRouteRequestHeader.h     |   0
 {src => cpp/src}/main/cpp/remoting/include/QueueData.h      |   0
 .../src}/main/cpp/remoting/include/RemotingCommand.h        |   0
 .../src}/main/cpp/remoting/include/RemotingCommandType.h    |   0
 {src => cpp/src}/main/cpp/remoting/include/RequestCode.h    |   0
 {src => cpp/src}/main/cpp/remoting/include/ResponseCode.h   |   0
 {src => cpp/src}/main/cpp/remoting/include/TopicRouteData.h |   0
 {src => cpp/src}/main/cpp/remoting/include/Version.h        |   0
 .../src}/main/cpp/rocketmq/AsyncReceiveMessageCallback.cpp  |   0
 {src => cpp/src}/main/cpp/rocketmq/BUILD.bazel              |   0
 {src => cpp/src}/main/cpp/rocketmq/ClientImpl.cpp           |   0
 .../src}/main/cpp/rocketmq/ConsumeMessageServiceImpl.cpp    |   0
 {src => cpp/src}/main/cpp/rocketmq/ConsumeTask.cpp          |   0
 .../src}/main/cpp/rocketmq/DynamicNameServerResolver.cpp    |   0
 .../src}/main/cpp/rocketmq/MessageGroupQueueSelector.cpp    |   0
 {src => cpp/src}/main/cpp/rocketmq/NamingScheme.cpp         |   0
 {src => cpp/src}/main/cpp/rocketmq/ProcessQueueImpl.cpp     |   0
 {src => cpp/src}/main/cpp/rocketmq/Producer.cpp             |   0
 {src => cpp/src}/main/cpp/rocketmq/ProducerImpl.cpp         |   0
 {src => cpp/src}/main/cpp/rocketmq/PushConsumer.cpp         |   0
 {src => cpp/src}/main/cpp/rocketmq/PushConsumerImpl.cpp     |   0
 {src => cpp/src}/main/cpp/rocketmq/SendContext.cpp          |   0
 {src => cpp/src}/main/cpp/rocketmq/SimpleConsumer.cpp       |   0
 {src => cpp/src}/main/cpp/rocketmq/SimpleConsumerImpl.cpp   |   0
 .../src}/main/cpp/rocketmq/StaticNameServerResolver.cpp     |   0
 {src => cpp/src}/main/cpp/rocketmq/TopicPublishInfo.cpp     |   0
 {src => cpp/src}/main/cpp/rocketmq/TransactionImpl.cpp      |   0
 .../main/cpp/rocketmq/include/AsyncReceiveMessageCallback.h |   0
 {src => cpp/src}/main/cpp/rocketmq/include/ClientImpl.h     |   0
 .../src}/main/cpp/rocketmq/include/ClientResourceBundle.h   |   0
 .../src}/main/cpp/rocketmq/include/ConsumeMessageService.h  |   0
 .../main/cpp/rocketmq/include/ConsumeMessageServiceImpl.h   |   0
 {src => cpp/src}/main/cpp/rocketmq/include/ConsumeTask.h    |   0
 {src => cpp/src}/main/cpp/rocketmq/include/Consumer.h       |   0
 .../main/cpp/rocketmq/include/DynamicNameServerResolver.h   |   0
 .../main/cpp/rocketmq/include/MessageGroupQueueSelector.h   |   0
 .../src}/main/cpp/rocketmq/include/NameServerResolver.h     |   0
 {src => cpp/src}/main/cpp/rocketmq/include/NamingScheme.h   |   0
 {src => cpp/src}/main/cpp/rocketmq/include/ProcessQueue.h   |   0
 .../src}/main/cpp/rocketmq/include/ProcessQueueImpl.h       |   0
 {src => cpp/src}/main/cpp/rocketmq/include/ProducerImpl.h   |   0
 .../src}/main/cpp/rocketmq/include/PublishInfoCallback.h    |   0
 .../src}/main/cpp/rocketmq/include/PushConsumerImpl.h       |   0
 {src => cpp/src}/main/cpp/rocketmq/include/SendContext.h    |   0
 .../src}/main/cpp/rocketmq/include/SimpleConsumerImpl.h     |   0
 .../main/cpp/rocketmq/include/StaticNameServerResolver.h    |   0
 .../src}/main/cpp/rocketmq/include/TopicPublishInfo.h       |   0
 .../src}/main/cpp/rocketmq/include/TransactionImpl.h        |   0
 {src => cpp/src}/main/cpp/rocketmq/mocks/BUILD.bazel        |   0
 .../cpp/rocketmq/mocks/include/ConsumeMessageServiceMock.h  |   0
 .../src}/main/cpp/rocketmq/mocks/include/ConsumerMock.h     |   0
 .../cpp/rocketmq/mocks/include/NameServerResolverMock.h     |   0
 .../src}/main/cpp/rocketmq/mocks/include/ProcessQueueMock.h |   0
 .../src}/main/cpp/rocketmq/mocks/include/PushConsumerMock.h |   0
 {src => cpp/src}/main/cpp/rocketmq/tests/BUILD.bazel        |   0
 .../src}/main/cpp/rocketmq/tests/SendContextTest.cpp        |   0
 {src => cpp/src}/main/cpp/rocketmq/tests/TimeTest.cpp       |   0
 {src => cpp/src}/main/cpp/scheduler/BUILD.bazel             |   0
 {src => cpp/src}/main/cpp/scheduler/SchedulerImpl.cpp       |   0
 {src => cpp/src}/main/cpp/scheduler/include/Scheduler.h     |   0
 {src => cpp/src}/main/cpp/scheduler/include/SchedulerImpl.h |   0
 {src => cpp/src}/main/cpp/stats/BUILD.bazel                 |   0
 {src => cpp/src}/main/cpp/stats/ConsumeStats.cpp            |   0
 {src => cpp/src}/main/cpp/stats/MetricBidiReactor.cpp       |   0
 {src => cpp/src}/main/cpp/stats/OpencensusExporter.cpp      |   0
 {src => cpp/src}/main/cpp/stats/PublishStats.cpp            |   0
 {src => cpp/src}/main/cpp/stats/Tag.cpp                     |   0
 {src => cpp/src}/main/cpp/stats/include/ConsumeStats.h      |   0
 {src => cpp/src}/main/cpp/stats/include/Exporter.h          |   0
 {src => cpp/src}/main/cpp/stats/include/MetricBidiReactor.h |   0
 .../src}/main/cpp/stats/include/OpencensusExporter.h        |   0
 {src => cpp/src}/main/cpp/stats/include/PublishStats.h      |   0
 {src => cpp/src}/main/cpp/stats/include/Tag.h               |   0
 {src => cpp/src}/main/cpp/stats/tests/BUILD.bazel           |   0
 {src => cpp/src}/main/cpp/stats/tests/PublishStatsTest.cpp  |   0
 {src => cpp/src}/main/cpp/trace/BUILD.bazel                 |   0
 {src => cpp/src}/main/cpp/trace/TracingUtility.cpp          |   0
 {src => cpp/src}/main/cpp/trace/include/TracingUtility.h    |   0
 {third_party => cpp/third_party}/BUILD.bazel                |   0
 {third_party => cpp/third_party}/ThreadPool.BUILD           |   0
 {third_party => cpp/third_party}/asio.BUILD                 |   0
 {third_party => cpp/third_party}/cpp_httplib.BUILD          |   0
 {third_party => cpp/third_party}/curl.BUILD                 |   0
 {third_party => cpp/third_party}/filesystem.BUILD           |   0
 {third_party => cpp/third_party}/fmtlib.BUILD               |   0
 {third_party => cpp/third_party}/spdlog.BUILD               |   0
 {tools => cpp/tools}/copyright.txt                          |   0
 {tools => cpp/tools}/coverage.sh                            |   0
 {tools => cpp/tools}/fix_copyright.py                       |   0
 {tools => cpp/tools}/format.sh                              |   0
 {tools => cpp/tools}/trouble_shooting.sh                    |   0
 {tools => cpp/tools}/use_clang.sh                           |   0
 274 files changed, 0 insertions(+), 0 deletions(-)

diff --git a/.bazelignore b/cpp/.bazelignore
similarity index 100%
rename from .bazelignore
rename to cpp/.bazelignore
diff --git a/.bazelrc b/cpp/.bazelrc
similarity index 100%
rename from .bazelrc
rename to cpp/.bazelrc
diff --git a/.bazelversion b/cpp/.bazelversion
similarity index 100%
rename from .bazelversion
rename to cpp/.bazelversion
diff --git a/.clang-format b/cpp/.clang-format
similarity index 100%
rename from .clang-format
rename to cpp/.clang-format
diff --git a/.clang-tidy b/cpp/.clang-tidy
similarity index 100%
rename from .clang-tidy
rename to cpp/.clang-tidy
diff --git a/.gitignore b/cpp/.gitignore
similarity index 100%
rename from .gitignore
rename to cpp/.gitignore
diff --git a/.travis.yml b/cpp/.travis.yml
similarity index 100%
rename from .travis.yml
rename to cpp/.travis.yml
diff --git a/BUILD.bazel b/cpp/BUILD.bazel
similarity index 100%
rename from BUILD.bazel
rename to cpp/BUILD.bazel
diff --git a/LICENSE b/cpp/LICENSE
similarity index 100%
rename from LICENSE
rename to cpp/LICENSE
diff --git a/README.md b/cpp/README.md
similarity index 100%
rename from README.md
rename to cpp/README.md
diff --git a/WORKSPACE b/cpp/WORKSPACE
similarity index 100%
rename from WORKSPACE
rename to cpp/WORKSPACE
diff --git a/api/BUILD.bazel b/cpp/api/BUILD.bazel
similarity index 100%
rename from api/BUILD.bazel
rename to cpp/api/BUILD.bazel
diff --git a/api/rocketmq/AdminServer.h b/cpp/api/rocketmq/AdminServer.h
similarity index 100%
rename from api/rocketmq/AdminServer.h
rename to cpp/api/rocketmq/AdminServer.h
diff --git a/api/rocketmq/BackoffPolicy.h b/cpp/api/rocketmq/BackoffPolicy.h
similarity index 100%
rename from api/rocketmq/BackoffPolicy.h
rename to cpp/api/rocketmq/BackoffPolicy.h
diff --git a/api/rocketmq/Configuration.h b/cpp/api/rocketmq/Configuration.h
similarity index 100%
rename from api/rocketmq/Configuration.h
rename to cpp/api/rocketmq/Configuration.h
diff --git a/api/rocketmq/ConfigurationDefaults.h b/cpp/api/rocketmq/ConfigurationDefaults.h
similarity index 100%
rename from api/rocketmq/ConfigurationDefaults.h
rename to cpp/api/rocketmq/ConfigurationDefaults.h
diff --git a/api/rocketmq/ConsumeResult.h b/cpp/api/rocketmq/ConsumeResult.h
similarity index 100%
rename from api/rocketmq/ConsumeResult.h
rename to cpp/api/rocketmq/ConsumeResult.h
diff --git a/api/rocketmq/Credentials.h b/cpp/api/rocketmq/Credentials.h
similarity index 100%
rename from api/rocketmq/Credentials.h
rename to cpp/api/rocketmq/Credentials.h
diff --git a/api/rocketmq/CredentialsProvider.h b/cpp/api/rocketmq/CredentialsProvider.h
similarity index 100%
rename from api/rocketmq/CredentialsProvider.h
rename to cpp/api/rocketmq/CredentialsProvider.h
diff --git a/api/rocketmq/ErrorCategory.h b/cpp/api/rocketmq/ErrorCategory.h
similarity index 100%
rename from api/rocketmq/ErrorCategory.h
rename to cpp/api/rocketmq/ErrorCategory.h
diff --git a/api/rocketmq/ErrorCode.h b/cpp/api/rocketmq/ErrorCode.h
similarity index 100%
rename from api/rocketmq/ErrorCode.h
rename to cpp/api/rocketmq/ErrorCode.h
diff --git a/api/rocketmq/Executor.h b/cpp/api/rocketmq/Executor.h
similarity index 100%
rename from api/rocketmq/Executor.h
rename to cpp/api/rocketmq/Executor.h
diff --git a/api/rocketmq/ExpressionType.h b/cpp/api/rocketmq/ExpressionType.h
similarity index 100%
rename from api/rocketmq/ExpressionType.h
rename to cpp/api/rocketmq/ExpressionType.h
diff --git a/api/rocketmq/FilterExpression.h b/cpp/api/rocketmq/FilterExpression.h
similarity index 100%
rename from api/rocketmq/FilterExpression.h
rename to cpp/api/rocketmq/FilterExpression.h
diff --git a/api/rocketmq/Logger.h b/cpp/api/rocketmq/Logger.h
similarity index 100%
rename from api/rocketmq/Logger.h
rename to cpp/api/rocketmq/Logger.h
diff --git a/api/rocketmq/MQClientException.h b/cpp/api/rocketmq/MQClientException.h
similarity index 100%
rename from api/rocketmq/MQClientException.h
rename to cpp/api/rocketmq/MQClientException.h
diff --git a/api/rocketmq/Message.h b/cpp/api/rocketmq/Message.h
similarity index 100%
rename from api/rocketmq/Message.h
rename to cpp/api/rocketmq/Message.h
diff --git a/api/rocketmq/MessageListener.h b/cpp/api/rocketmq/MessageListener.h
similarity index 100%
rename from api/rocketmq/MessageListener.h
rename to cpp/api/rocketmq/MessageListener.h
diff --git a/api/rocketmq/Producer.h b/cpp/api/rocketmq/Producer.h
similarity index 100%
rename from api/rocketmq/Producer.h
rename to cpp/api/rocketmq/Producer.h
diff --git a/api/rocketmq/PushConsumer.h b/cpp/api/rocketmq/PushConsumer.h
similarity index 100%
rename from api/rocketmq/PushConsumer.h
rename to cpp/api/rocketmq/PushConsumer.h
diff --git a/api/rocketmq/RocketMQ.h b/cpp/api/rocketmq/RocketMQ.h
similarity index 100%
rename from api/rocketmq/RocketMQ.h
rename to cpp/api/rocketmq/RocketMQ.h
diff --git a/api/rocketmq/SendCallback.h b/cpp/api/rocketmq/SendCallback.h
similarity index 100%
rename from api/rocketmq/SendCallback.h
rename to cpp/api/rocketmq/SendCallback.h
diff --git a/api/rocketmq/SendReceipt.h b/cpp/api/rocketmq/SendReceipt.h
similarity index 100%
rename from api/rocketmq/SendReceipt.h
rename to cpp/api/rocketmq/SendReceipt.h
diff --git a/api/rocketmq/SimpleConsumer.h b/cpp/api/rocketmq/SimpleConsumer.h
similarity index 100%
rename from api/rocketmq/SimpleConsumer.h
rename to cpp/api/rocketmq/SimpleConsumer.h
diff --git a/api/rocketmq/State.h b/cpp/api/rocketmq/State.h
similarity index 100%
rename from api/rocketmq/State.h
rename to cpp/api/rocketmq/State.h
diff --git a/api/rocketmq/Tracing.h b/cpp/api/rocketmq/Tracing.h
similarity index 100%
rename from api/rocketmq/Tracing.h
rename to cpp/api/rocketmq/Tracing.h
diff --git a/api/rocketmq/Transaction.h b/cpp/api/rocketmq/Transaction.h
similarity index 100%
rename from api/rocketmq/Transaction.h
rename to cpp/api/rocketmq/Transaction.h
diff --git a/api/rocketmq/TransactionChecker.h b/cpp/api/rocketmq/TransactionChecker.h
similarity index 100%
rename from api/rocketmq/TransactionChecker.h
rename to cpp/api/rocketmq/TransactionChecker.h
diff --git a/api/rocketmq/TransactionState.h b/cpp/api/rocketmq/TransactionState.h
similarity index 100%
rename from api/rocketmq/TransactionState.h
rename to cpp/api/rocketmq/TransactionState.h
diff --git a/bazel/BUILD.bazel b/cpp/bazel/BUILD.bazel
similarity index 100%
rename from bazel/BUILD.bazel
rename to cpp/bazel/BUILD.bazel
diff --git a/bazel/curl.bzl b/cpp/bazel/curl.bzl
similarity index 100%
rename from bazel/curl.bzl
rename to cpp/bazel/curl.bzl
diff --git a/bazel/rocketmq_deps.bzl b/cpp/bazel/rocketmq_deps.bzl
similarity index 100%
rename from bazel/rocketmq_deps.bzl
rename to cpp/bazel/rocketmq_deps.bzl
diff --git a/ci/build.sh b/cpp/ci/build.sh
similarity index 100%
rename from ci/build.sh
rename to cpp/ci/build.sh
diff --git a/docs/assets/BasicMode.png b/cpp/docs/assets/BasicMode.png
similarity index 100%
rename from docs/assets/BasicMode.png
rename to cpp/docs/assets/BasicMode.png
diff --git a/docs/assets/class_diagram.png b/cpp/docs/assets/class_diagram.png
similarity index 100%
rename from docs/assets/class_diagram.png
rename to cpp/docs/assets/class_diagram.png
diff --git a/docs/gtest.md b/cpp/docs/gtest.md
similarity index 100%
rename from docs/gtest.md
rename to cpp/docs/gtest.md
diff --git a/docs/test_coverage.md b/cpp/docs/test_coverage.md
similarity index 100%
rename from docs/test_coverage.md
rename to cpp/docs/test_coverage.md
diff --git a/examples/BUILD.bazel b/cpp/examples/BUILD.bazel
similarity index 100%
rename from examples/BUILD.bazel
rename to cpp/examples/BUILD.bazel
diff --git a/examples/BenchmarkPushConsumer.cpp b/cpp/examples/BenchmarkPushConsumer.cpp
similarity index 100%
rename from examples/BenchmarkPushConsumer.cpp
rename to cpp/examples/BenchmarkPushConsumer.cpp
diff --git a/examples/ExampleAsyncProducer.cpp b/cpp/examples/ExampleAsyncProducer.cpp
similarity index 100%
rename from examples/ExampleAsyncProducer.cpp
rename to cpp/examples/ExampleAsyncProducer.cpp
diff --git a/examples/ExampleFifoProducer.cpp b/cpp/examples/ExampleFifoProducer.cpp
similarity index 100%
rename from examples/ExampleFifoProducer.cpp
rename to cpp/examples/ExampleFifoProducer.cpp
diff --git a/examples/ExampleFifoPushConsumer.cpp b/cpp/examples/ExampleFifoPushConsumer.cpp
similarity index 100%
rename from examples/ExampleFifoPushConsumer.cpp
rename to cpp/examples/ExampleFifoPushConsumer.cpp
diff --git a/examples/ExampleProducer.cpp b/cpp/examples/ExampleProducer.cpp
similarity index 100%
rename from examples/ExampleProducer.cpp
rename to cpp/examples/ExampleProducer.cpp
diff --git a/examples/ExamplePushConsumer.cpp b/cpp/examples/ExamplePushConsumer.cpp
similarity index 100%
rename from examples/ExamplePushConsumer.cpp
rename to cpp/examples/ExamplePushConsumer.cpp
diff --git a/examples/ExampleSimpleConsumer.cpp b/cpp/examples/ExampleSimpleConsumer.cpp
similarity index 100%
rename from examples/ExampleSimpleConsumer.cpp
rename to cpp/examples/ExampleSimpleConsumer.cpp
diff --git a/examples/ExampleTransactionProducer.cpp b/cpp/examples/ExampleTransactionProducer.cpp
similarity index 100%
rename from examples/ExampleTransactionProducer.cpp
rename to cpp/examples/ExampleTransactionProducer.cpp
diff --git a/examples/PushConsumerWithCustomExecutor.cpp b/cpp/examples/PushConsumerWithCustomExecutor.cpp
similarity index 100%
rename from examples/PushConsumerWithCustomExecutor.cpp
rename to cpp/examples/PushConsumerWithCustomExecutor.cpp
diff --git a/examples/PushConsumerWithThrottle.cpp b/cpp/examples/PushConsumerWithThrottle.cpp
similarity index 100%
rename from examples/PushConsumerWithThrottle.cpp
rename to cpp/examples/PushConsumerWithThrottle.cpp
diff --git a/examples/SqlConsumer.cpp b/cpp/examples/SqlConsumer.cpp
similarity index 100%
rename from examples/SqlConsumer.cpp
rename to cpp/examples/SqlConsumer.cpp
diff --git a/examples/SqlProducer.cpp b/cpp/examples/SqlProducer.cpp
similarity index 100%
rename from examples/SqlProducer.cpp
rename to cpp/examples/SqlProducer.cpp
diff --git a/proto/BUILD.bazel b/cpp/proto/BUILD.bazel
similarity index 100%
rename from proto/BUILD.bazel
rename to cpp/proto/BUILD.bazel
diff --git a/proto/apache/rocketmq/v2/admin.proto b/cpp/proto/apache/rocketmq/v2/admin.proto
similarity index 100%
rename from proto/apache/rocketmq/v2/admin.proto
rename to cpp/proto/apache/rocketmq/v2/admin.proto
diff --git a/proto/apache/rocketmq/v2/definition.proto b/cpp/proto/apache/rocketmq/v2/definition.proto
similarity index 100%
rename from proto/apache/rocketmq/v2/definition.proto
rename to cpp/proto/apache/rocketmq/v2/definition.proto
diff --git a/proto/apache/rocketmq/v2/service.proto b/cpp/proto/apache/rocketmq/v2/service.proto
similarity index 100%
rename from proto/apache/rocketmq/v2/service.proto
rename to cpp/proto/apache/rocketmq/v2/service.proto
diff --git a/src/main/cpp/admin/AdminClient.cpp b/cpp/src/main/cpp/admin/AdminClient.cpp
similarity index 100%
rename from src/main/cpp/admin/AdminClient.cpp
rename to cpp/src/main/cpp/admin/AdminClient.cpp
diff --git a/src/main/cpp/admin/AdminFacade.cpp b/cpp/src/main/cpp/admin/AdminFacade.cpp
similarity index 100%
rename from src/main/cpp/admin/AdminFacade.cpp
rename to cpp/src/main/cpp/admin/AdminFacade.cpp
diff --git a/src/main/cpp/admin/AdminServerImpl.cpp b/cpp/src/main/cpp/admin/AdminServerImpl.cpp
similarity index 100%
rename from src/main/cpp/admin/AdminServerImpl.cpp
rename to cpp/src/main/cpp/admin/AdminServerImpl.cpp
diff --git a/src/main/cpp/admin/AdminServiceImpl.cpp b/cpp/src/main/cpp/admin/AdminServiceImpl.cpp
similarity index 100%
rename from src/main/cpp/admin/AdminServiceImpl.cpp
rename to cpp/src/main/cpp/admin/AdminServiceImpl.cpp
diff --git a/src/main/cpp/admin/BUILD.bazel b/cpp/src/main/cpp/admin/BUILD.bazel
similarity index 100%
rename from src/main/cpp/admin/BUILD.bazel
rename to cpp/src/main/cpp/admin/BUILD.bazel
diff --git a/src/main/cpp/admin/include/AdminClient.h b/cpp/src/main/cpp/admin/include/AdminClient.h
similarity index 100%
rename from src/main/cpp/admin/include/AdminClient.h
rename to cpp/src/main/cpp/admin/include/AdminClient.h
diff --git a/src/main/cpp/admin/include/AdminServerImpl.h b/cpp/src/main/cpp/admin/include/AdminServerImpl.h
similarity index 100%
rename from src/main/cpp/admin/include/AdminServerImpl.h
rename to cpp/src/main/cpp/admin/include/AdminServerImpl.h
diff --git a/src/main/cpp/admin/include/AdminServiceImpl.h b/cpp/src/main/cpp/admin/include/AdminServiceImpl.h
similarity index 100%
rename from src/main/cpp/admin/include/AdminServiceImpl.h
rename to cpp/src/main/cpp/admin/include/AdminServiceImpl.h
diff --git a/src/main/cpp/admin/include/ServerCall.h b/cpp/src/main/cpp/admin/include/ServerCall.h
similarity index 100%
rename from src/main/cpp/admin/include/ServerCall.h
rename to cpp/src/main/cpp/admin/include/ServerCall.h
diff --git a/src/main/cpp/base/BUILD.bazel b/cpp/src/main/cpp/base/BUILD.bazel
similarity index 100%
rename from src/main/cpp/base/BUILD.bazel
rename to cpp/src/main/cpp/base/BUILD.bazel
diff --git a/src/main/cpp/base/Configuration.cpp b/cpp/src/main/cpp/base/Configuration.cpp
similarity index 100%
rename from src/main/cpp/base/Configuration.cpp
rename to cpp/src/main/cpp/base/Configuration.cpp
diff --git a/src/main/cpp/base/ConfigurationDefaults.cpp b/cpp/src/main/cpp/base/ConfigurationDefaults.cpp
similarity index 100%
rename from src/main/cpp/base/ConfigurationDefaults.cpp
rename to cpp/src/main/cpp/base/ConfigurationDefaults.cpp
diff --git a/src/main/cpp/base/CredentialsProvider.cpp b/cpp/src/main/cpp/base/CredentialsProvider.cpp
similarity index 100%
rename from src/main/cpp/base/CredentialsProvider.cpp
rename to cpp/src/main/cpp/base/CredentialsProvider.cpp
diff --git a/src/main/cpp/base/ErrorCategory.cpp b/cpp/src/main/cpp/base/ErrorCategory.cpp
similarity index 100%
rename from src/main/cpp/base/ErrorCategory.cpp
rename to cpp/src/main/cpp/base/ErrorCategory.cpp
diff --git a/src/main/cpp/base/ErrorCode.cpp b/cpp/src/main/cpp/base/ErrorCode.cpp
similarity index 100%
rename from src/main/cpp/base/ErrorCode.cpp
rename to cpp/src/main/cpp/base/ErrorCode.cpp
diff --git a/src/main/cpp/base/FilterExpression.cpp b/cpp/src/main/cpp/base/FilterExpression.cpp
similarity index 100%
rename from src/main/cpp/base/FilterExpression.cpp
rename to cpp/src/main/cpp/base/FilterExpression.cpp
diff --git a/src/main/cpp/base/HostInfo.cpp b/cpp/src/main/cpp/base/HostInfo.cpp
similarity index 100%
rename from src/main/cpp/base/HostInfo.cpp
rename to cpp/src/main/cpp/base/HostInfo.cpp
diff --git a/src/main/cpp/base/HttpClientImpl.cpp b/cpp/src/main/cpp/base/HttpClientImpl.cpp
similarity index 100%
rename from src/main/cpp/base/HttpClientImpl.cpp
rename to cpp/src/main/cpp/base/HttpClientImpl.cpp
diff --git a/src/main/cpp/base/Message.cpp b/cpp/src/main/cpp/base/Message.cpp
similarity index 100%
rename from src/main/cpp/base/Message.cpp
rename to cpp/src/main/cpp/base/Message.cpp
diff --git a/src/main/cpp/base/MessageExt.cpp b/cpp/src/main/cpp/base/MessageExt.cpp
similarity index 100%
rename from src/main/cpp/base/MessageExt.cpp
rename to cpp/src/main/cpp/base/MessageExt.cpp
diff --git a/src/main/cpp/base/MetadataConstants.cpp b/cpp/src/main/cpp/base/MetadataConstants.cpp
similarity index 100%
rename from src/main/cpp/base/MetadataConstants.cpp
rename to cpp/src/main/cpp/base/MetadataConstants.cpp
diff --git a/src/main/cpp/base/MixAll.cpp b/cpp/src/main/cpp/base/MixAll.cpp
similarity index 100%
rename from src/main/cpp/base/MixAll.cpp
rename to cpp/src/main/cpp/base/MixAll.cpp
diff --git a/src/main/cpp/base/Protocol.cpp b/cpp/src/main/cpp/base/Protocol.cpp
similarity index 100%
rename from src/main/cpp/base/Protocol.cpp
rename to cpp/src/main/cpp/base/Protocol.cpp
diff --git a/src/main/cpp/base/RateLimiter.cpp b/cpp/src/main/cpp/base/RateLimiter.cpp
similarity index 100%
rename from src/main/cpp/base/RateLimiter.cpp
rename to cpp/src/main/cpp/base/RateLimiter.cpp
diff --git a/src/main/cpp/base/ThreadPoolImpl.cpp b/cpp/src/main/cpp/base/ThreadPoolImpl.cpp
similarity index 100%
rename from src/main/cpp/base/ThreadPoolImpl.cpp
rename to cpp/src/main/cpp/base/ThreadPoolImpl.cpp
diff --git a/src/main/cpp/base/TopAddressing.cpp b/cpp/src/main/cpp/base/TopAddressing.cpp
similarity index 100%
rename from src/main/cpp/base/TopAddressing.cpp
rename to cpp/src/main/cpp/base/TopAddressing.cpp
diff --git a/src/main/cpp/base/Tracing.cpp b/cpp/src/main/cpp/base/Tracing.cpp
similarity index 100%
rename from src/main/cpp/base/Tracing.cpp
rename to cpp/src/main/cpp/base/Tracing.cpp
diff --git a/src/main/cpp/base/UniqueIdGenerator.cpp b/cpp/src/main/cpp/base/UniqueIdGenerator.cpp
similarity index 100%
rename from src/main/cpp/base/UniqueIdGenerator.cpp
rename to cpp/src/main/cpp/base/UniqueIdGenerator.cpp
diff --git a/src/main/cpp/base/UtilAll.cpp b/cpp/src/main/cpp/base/UtilAll.cpp
similarity index 100%
rename from src/main/cpp/base/UtilAll.cpp
rename to cpp/src/main/cpp/base/UtilAll.cpp
diff --git a/src/main/cpp/base/include/Histogram.h b/cpp/src/main/cpp/base/include/Histogram.h
similarity index 100%
rename from src/main/cpp/base/include/Histogram.h
rename to cpp/src/main/cpp/base/include/Histogram.h
diff --git a/src/main/cpp/base/include/HostInfo.h b/cpp/src/main/cpp/base/include/HostInfo.h
similarity index 100%
rename from src/main/cpp/base/include/HostInfo.h
rename to cpp/src/main/cpp/base/include/HostInfo.h
diff --git a/src/main/cpp/base/include/HttpClient.h b/cpp/src/main/cpp/base/include/HttpClient.h
similarity index 100%
rename from src/main/cpp/base/include/HttpClient.h
rename to cpp/src/main/cpp/base/include/HttpClient.h
diff --git a/src/main/cpp/base/include/HttpClientImpl.h b/cpp/src/main/cpp/base/include/HttpClientImpl.h
similarity index 100%
rename from src/main/cpp/base/include/HttpClientImpl.h
rename to cpp/src/main/cpp/base/include/HttpClientImpl.h
diff --git a/src/main/cpp/base/include/InvocationContext.h b/cpp/src/main/cpp/base/include/InvocationContext.h
similarity index 100%
rename from src/main/cpp/base/include/InvocationContext.h
rename to cpp/src/main/cpp/base/include/InvocationContext.h
diff --git a/src/main/cpp/base/include/MessageExt.h b/cpp/src/main/cpp/base/include/MessageExt.h
similarity index 100%
rename from src/main/cpp/base/include/MessageExt.h
rename to cpp/src/main/cpp/base/include/MessageExt.h
diff --git a/src/main/cpp/base/include/MetadataConstants.h b/cpp/src/main/cpp/base/include/MetadataConstants.h
similarity index 100%
rename from src/main/cpp/base/include/MetadataConstants.h
rename to cpp/src/main/cpp/base/include/MetadataConstants.h
diff --git a/src/main/cpp/base/include/MixAll.h b/cpp/src/main/cpp/base/include/MixAll.h
similarity index 100%
rename from src/main/cpp/base/include/MixAll.h
rename to cpp/src/main/cpp/base/include/MixAll.h
diff --git a/src/main/cpp/base/include/Protocol.h b/cpp/src/main/cpp/base/include/Protocol.h
similarity index 100%
rename from src/main/cpp/base/include/Protocol.h
rename to cpp/src/main/cpp/base/include/Protocol.h
diff --git a/src/main/cpp/base/include/RateLimiter.h b/cpp/src/main/cpp/base/include/RateLimiter.h
similarity index 100%
rename from src/main/cpp/base/include/RateLimiter.h
rename to cpp/src/main/cpp/base/include/RateLimiter.h
diff --git a/src/main/cpp/base/include/RetryPolicy.h b/cpp/src/main/cpp/base/include/RetryPolicy.h
similarity index 100%
rename from src/main/cpp/base/include/RetryPolicy.h
rename to cpp/src/main/cpp/base/include/RetryPolicy.h
diff --git a/src/main/cpp/base/include/StsCredentialsProviderImpl.h b/cpp/src/main/cpp/base/include/StsCredentialsProviderImpl.h
similarity index 100%
rename from src/main/cpp/base/include/StsCredentialsProviderImpl.h
rename to cpp/src/main/cpp/base/include/StsCredentialsProviderImpl.h
diff --git a/src/main/cpp/base/include/SubscriptionEntry.h b/cpp/src/main/cpp/base/include/SubscriptionEntry.h
similarity index 100%
rename from src/main/cpp/base/include/SubscriptionEntry.h
rename to cpp/src/main/cpp/base/include/SubscriptionEntry.h
diff --git a/src/main/cpp/base/include/ThreadPool.h b/cpp/src/main/cpp/base/include/ThreadPool.h
similarity index 100%
rename from src/main/cpp/base/include/ThreadPool.h
rename to cpp/src/main/cpp/base/include/ThreadPool.h
diff --git a/src/main/cpp/base/include/ThreadPoolImpl.h b/cpp/src/main/cpp/base/include/ThreadPoolImpl.h
similarity index 100%
rename from src/main/cpp/base/include/ThreadPoolImpl.h
rename to cpp/src/main/cpp/base/include/ThreadPoolImpl.h
diff --git a/src/main/cpp/base/include/TopAddressing.h b/cpp/src/main/cpp/base/include/TopAddressing.h
similarity index 100%
rename from src/main/cpp/base/include/TopAddressing.h
rename to cpp/src/main/cpp/base/include/TopAddressing.h
diff --git a/src/main/cpp/base/include/UniqueIdGenerator.h b/cpp/src/main/cpp/base/include/UniqueIdGenerator.h
similarity index 100%
rename from src/main/cpp/base/include/UniqueIdGenerator.h
rename to cpp/src/main/cpp/base/include/UniqueIdGenerator.h
diff --git a/src/main/cpp/base/include/UtilAll.h b/cpp/src/main/cpp/base/include/UtilAll.h
similarity index 100%
rename from src/main/cpp/base/include/UtilAll.h
rename to cpp/src/main/cpp/base/include/UtilAll.h
diff --git a/src/main/cpp/base/mocks/BUILD.bazel b/cpp/src/main/cpp/base/mocks/BUILD.bazel
similarity index 100%
rename from src/main/cpp/base/mocks/BUILD.bazel
rename to cpp/src/main/cpp/base/mocks/BUILD.bazel
diff --git a/src/main/cpp/base/mocks/include/HttpClientMock.h b/cpp/src/main/cpp/base/mocks/include/HttpClientMock.h
similarity index 100%
rename from src/main/cpp/base/mocks/include/HttpClientMock.h
rename to cpp/src/main/cpp/base/mocks/include/HttpClientMock.h
diff --git a/src/main/cpp/base/mocks/include/MessageListenerMock.h b/cpp/src/main/cpp/base/mocks/include/MessageListenerMock.h
similarity index 100%
rename from src/main/cpp/base/mocks/include/MessageListenerMock.h
rename to cpp/src/main/cpp/base/mocks/include/MessageListenerMock.h
diff --git a/src/main/cpp/base/tests/AssignmentTest.cpp b/cpp/src/main/cpp/base/tests/AssignmentTest.cpp
similarity index 100%
rename from src/main/cpp/base/tests/AssignmentTest.cpp
rename to cpp/src/main/cpp/base/tests/AssignmentTest.cpp
diff --git a/src/main/cpp/base/tests/BUILD.bazel b/cpp/src/main/cpp/base/tests/BUILD.bazel
similarity index 100%
rename from src/main/cpp/base/tests/BUILD.bazel
rename to cpp/src/main/cpp/base/tests/BUILD.bazel
diff --git a/src/main/cpp/base/tests/ConfigurationTest.cpp b/cpp/src/main/cpp/base/tests/ConfigurationTest.cpp
similarity index 100%
rename from src/main/cpp/base/tests/ConfigurationTest.cpp
rename to cpp/src/main/cpp/base/tests/ConfigurationTest.cpp
diff --git a/src/main/cpp/base/tests/MessageBuilderTest.cpp b/cpp/src/main/cpp/base/tests/MessageBuilderTest.cpp
similarity index 100%
rename from src/main/cpp/base/tests/MessageBuilderTest.cpp
rename to cpp/src/main/cpp/base/tests/MessageBuilderTest.cpp
diff --git a/src/main/cpp/base/tests/MessageQueueTest.cpp b/cpp/src/main/cpp/base/tests/MessageQueueTest.cpp
similarity index 100%
rename from src/main/cpp/base/tests/MessageQueueTest.cpp
rename to cpp/src/main/cpp/base/tests/MessageQueueTest.cpp
diff --git a/src/main/cpp/base/tests/MixAllTest.cpp b/cpp/src/main/cpp/base/tests/MixAllTest.cpp
similarity index 100%
rename from src/main/cpp/base/tests/MixAllTest.cpp
rename to cpp/src/main/cpp/base/tests/MixAllTest.cpp
diff --git a/src/main/cpp/base/tests/RetryPolicyTest.cpp b/cpp/src/main/cpp/base/tests/RetryPolicyTest.cpp
similarity index 100%
rename from src/main/cpp/base/tests/RetryPolicyTest.cpp
rename to cpp/src/main/cpp/base/tests/RetryPolicyTest.cpp
diff --git a/src/main/cpp/client/BUILD.bazel b/cpp/src/main/cpp/client/BUILD.bazel
similarity index 100%
rename from src/main/cpp/client/BUILD.bazel
rename to cpp/src/main/cpp/client/BUILD.bazel
diff --git a/src/main/cpp/client/ClientManagerFactory.cpp b/cpp/src/main/cpp/client/ClientManagerFactory.cpp
similarity index 100%
rename from src/main/cpp/client/ClientManagerFactory.cpp
rename to cpp/src/main/cpp/client/ClientManagerFactory.cpp
diff --git a/src/main/cpp/client/ClientManagerImpl.cpp b/cpp/src/main/cpp/client/ClientManagerImpl.cpp
similarity index 100%
rename from src/main/cpp/client/ClientManagerImpl.cpp
rename to cpp/src/main/cpp/client/ClientManagerImpl.cpp
diff --git a/src/main/cpp/client/LogInterceptor.cpp b/cpp/src/main/cpp/client/LogInterceptor.cpp
similarity index 100%
rename from src/main/cpp/client/LogInterceptor.cpp
rename to cpp/src/main/cpp/client/LogInterceptor.cpp
diff --git a/src/main/cpp/client/LogInterceptorFactory.cpp b/cpp/src/main/cpp/client/LogInterceptorFactory.cpp
similarity index 100%
rename from src/main/cpp/client/LogInterceptorFactory.cpp
rename to cpp/src/main/cpp/client/LogInterceptorFactory.cpp
diff --git a/src/main/cpp/client/ReceiveMessageStreamReader.cpp b/cpp/src/main/cpp/client/ReceiveMessageStreamReader.cpp
similarity index 100%
rename from src/main/cpp/client/ReceiveMessageStreamReader.cpp
rename to cpp/src/main/cpp/client/ReceiveMessageStreamReader.cpp
diff --git a/src/main/cpp/client/RpcClientImpl.cpp b/cpp/src/main/cpp/client/RpcClientImpl.cpp
similarity index 100%
rename from src/main/cpp/client/RpcClientImpl.cpp
rename to cpp/src/main/cpp/client/RpcClientImpl.cpp
diff --git a/src/main/cpp/client/SessionImpl.cpp b/cpp/src/main/cpp/client/SessionImpl.cpp
similarity index 100%
rename from src/main/cpp/client/SessionImpl.cpp
rename to cpp/src/main/cpp/client/SessionImpl.cpp
diff --git a/src/main/cpp/client/Signature.cpp b/cpp/src/main/cpp/client/Signature.cpp
similarity index 100%
rename from src/main/cpp/client/Signature.cpp
rename to cpp/src/main/cpp/client/Signature.cpp
diff --git a/src/main/cpp/client/TelemetryBidiReactor.cpp b/cpp/src/main/cpp/client/TelemetryBidiReactor.cpp
similarity index 100%
rename from src/main/cpp/client/TelemetryBidiReactor.cpp
rename to cpp/src/main/cpp/client/TelemetryBidiReactor.cpp
diff --git a/src/main/cpp/client/TlsHelper.cpp b/cpp/src/main/cpp/client/TlsHelper.cpp
similarity index 100%
rename from src/main/cpp/client/TlsHelper.cpp
rename to cpp/src/main/cpp/client/TlsHelper.cpp
diff --git a/src/main/cpp/client/TopicAssignmentInfo.cpp b/cpp/src/main/cpp/client/TopicAssignmentInfo.cpp
similarity index 100%
rename from src/main/cpp/client/TopicAssignmentInfo.cpp
rename to cpp/src/main/cpp/client/TopicAssignmentInfo.cpp
diff --git a/src/main/cpp/client/include/Client.h b/cpp/src/main/cpp/client/include/Client.h
similarity index 100%
rename from src/main/cpp/client/include/Client.h
rename to cpp/src/main/cpp/client/include/Client.h
diff --git a/src/main/cpp/client/include/ClientConfig.h b/cpp/src/main/cpp/client/include/ClientConfig.h
similarity index 100%
rename from src/main/cpp/client/include/ClientConfig.h
rename to cpp/src/main/cpp/client/include/ClientConfig.h
diff --git a/src/main/cpp/client/include/ClientManager.h b/cpp/src/main/cpp/client/include/ClientManager.h
similarity index 100%
rename from src/main/cpp/client/include/ClientManager.h
rename to cpp/src/main/cpp/client/include/ClientManager.h
diff --git a/src/main/cpp/client/include/ClientManagerFactory.h b/cpp/src/main/cpp/client/include/ClientManagerFactory.h
similarity index 100%
rename from src/main/cpp/client/include/ClientManagerFactory.h
rename to cpp/src/main/cpp/client/include/ClientManagerFactory.h
diff --git a/src/main/cpp/client/include/ClientManagerImpl.h b/cpp/src/main/cpp/client/include/ClientManagerImpl.h
similarity index 100%
rename from src/main/cpp/client/include/ClientManagerImpl.h
rename to cpp/src/main/cpp/client/include/ClientManagerImpl.h
diff --git a/src/main/cpp/client/include/ConsumeMessageType.h b/cpp/src/main/cpp/client/include/ConsumeMessageType.h
similarity index 100%
rename from src/main/cpp/client/include/ConsumeMessageType.h
rename to cpp/src/main/cpp/client/include/ConsumeMessageType.h
diff --git a/src/main/cpp/client/include/HeartbeatDataCallback.h b/cpp/src/main/cpp/client/include/HeartbeatDataCallback.h
similarity index 100%
rename from src/main/cpp/client/include/HeartbeatDataCallback.h
rename to cpp/src/main/cpp/client/include/HeartbeatDataCallback.h
diff --git a/src/main/cpp/client/include/InsecureCertificateVerifier.h b/cpp/src/main/cpp/client/include/InsecureCertificateVerifier.h
similarity index 100%
rename from src/main/cpp/client/include/InsecureCertificateVerifier.h
rename to cpp/src/main/cpp/client/include/InsecureCertificateVerifier.h
diff --git a/src/main/cpp/client/include/InterceptorContinuation.h b/cpp/src/main/cpp/client/include/InterceptorContinuation.h
similarity index 100%
rename from src/main/cpp/client/include/InterceptorContinuation.h
rename to cpp/src/main/cpp/client/include/InterceptorContinuation.h
diff --git a/src/main/cpp/client/include/LogInterceptor.h b/cpp/src/main/cpp/client/include/LogInterceptor.h
similarity index 100%
rename from src/main/cpp/client/include/LogInterceptor.h
rename to cpp/src/main/cpp/client/include/LogInterceptor.h
diff --git a/src/main/cpp/client/include/LogInterceptorFactory.h b/cpp/src/main/cpp/client/include/LogInterceptorFactory.h
similarity index 100%
rename from src/main/cpp/client/include/LogInterceptorFactory.h
rename to cpp/src/main/cpp/client/include/LogInterceptorFactory.h
diff --git a/src/main/cpp/client/include/Metadata.h b/cpp/src/main/cpp/client/include/Metadata.h
similarity index 100%
rename from src/main/cpp/client/include/Metadata.h
rename to cpp/src/main/cpp/client/include/Metadata.h
diff --git a/src/main/cpp/client/include/OpenSSLCompatible.h b/cpp/src/main/cpp/client/include/OpenSSLCompatible.h
similarity index 100%
rename from src/main/cpp/client/include/OpenSSLCompatible.h
rename to cpp/src/main/cpp/client/include/OpenSSLCompatible.h
diff --git a/src/main/cpp/client/include/ReceiveMessageCallback.h b/cpp/src/main/cpp/client/include/ReceiveMessageCallback.h
similarity index 100%
rename from src/main/cpp/client/include/ReceiveMessageCallback.h
rename to cpp/src/main/cpp/client/include/ReceiveMessageCallback.h
diff --git a/src/main/cpp/client/include/ReceiveMessageContext.h b/cpp/src/main/cpp/client/include/ReceiveMessageContext.h
similarity index 100%
rename from src/main/cpp/client/include/ReceiveMessageContext.h
rename to cpp/src/main/cpp/client/include/ReceiveMessageContext.h
diff --git a/src/main/cpp/client/include/ReceiveMessageResult.h b/cpp/src/main/cpp/client/include/ReceiveMessageResult.h
similarity index 100%
rename from src/main/cpp/client/include/ReceiveMessageResult.h
rename to cpp/src/main/cpp/client/include/ReceiveMessageResult.h
diff --git a/src/main/cpp/client/include/ReceiveMessageStreamReader.h b/cpp/src/main/cpp/client/include/ReceiveMessageStreamReader.h
similarity index 100%
rename from src/main/cpp/client/include/ReceiveMessageStreamReader.h
rename to cpp/src/main/cpp/client/include/ReceiveMessageStreamReader.h
diff --git a/src/main/cpp/client/include/RpcClient.h b/cpp/src/main/cpp/client/include/RpcClient.h
similarity index 100%
rename from src/main/cpp/client/include/RpcClient.h
rename to cpp/src/main/cpp/client/include/RpcClient.h
diff --git a/src/main/cpp/client/include/RpcClientImpl.h b/cpp/src/main/cpp/client/include/RpcClientImpl.h
similarity index 100%
rename from src/main/cpp/client/include/RpcClientImpl.h
rename to cpp/src/main/cpp/client/include/RpcClientImpl.h
diff --git a/src/main/cpp/client/include/SendMessageContext.h b/cpp/src/main/cpp/client/include/SendMessageContext.h
similarity index 100%
rename from src/main/cpp/client/include/SendMessageContext.h
rename to cpp/src/main/cpp/client/include/SendMessageContext.h
diff --git a/src/main/cpp/client/include/Session.h b/cpp/src/main/cpp/client/include/Session.h
similarity index 100%
rename from src/main/cpp/client/include/Session.h
rename to cpp/src/main/cpp/client/include/Session.h
diff --git a/src/main/cpp/client/include/SessionImpl.h b/cpp/src/main/cpp/client/include/SessionImpl.h
similarity index 100%
rename from src/main/cpp/client/include/SessionImpl.h
rename to cpp/src/main/cpp/client/include/SessionImpl.h
diff --git a/src/main/cpp/client/include/Signature.h b/cpp/src/main/cpp/client/include/Signature.h
similarity index 100%
rename from src/main/cpp/client/include/Signature.h
rename to cpp/src/main/cpp/client/include/Signature.h
diff --git a/src/main/cpp/client/include/TelemetryBidiReactor.h b/cpp/src/main/cpp/client/include/TelemetryBidiReactor.h
similarity index 100%
rename from src/main/cpp/client/include/TelemetryBidiReactor.h
rename to cpp/src/main/cpp/client/include/TelemetryBidiReactor.h
diff --git a/src/main/cpp/client/include/TlsHelper.h b/cpp/src/main/cpp/client/include/TlsHelper.h
similarity index 100%
rename from src/main/cpp/client/include/TlsHelper.h
rename to cpp/src/main/cpp/client/include/TlsHelper.h
diff --git a/src/main/cpp/client/include/Topic.h b/cpp/src/main/cpp/client/include/Topic.h
similarity index 100%
rename from src/main/cpp/client/include/Topic.h
rename to cpp/src/main/cpp/client/include/Topic.h
diff --git a/src/main/cpp/client/include/TopicAssignmentInfo.h b/cpp/src/main/cpp/client/include/TopicAssignmentInfo.h
similarity index 100%
rename from src/main/cpp/client/include/TopicAssignmentInfo.h
rename to cpp/src/main/cpp/client/include/TopicAssignmentInfo.h
diff --git a/src/main/cpp/client/include/TopicRouteChangeCallback.h b/cpp/src/main/cpp/client/include/TopicRouteChangeCallback.h
similarity index 100%
rename from src/main/cpp/client/include/TopicRouteChangeCallback.h
rename to cpp/src/main/cpp/client/include/TopicRouteChangeCallback.h
diff --git a/src/main/cpp/client/include/TopicRouteData.h b/cpp/src/main/cpp/client/include/TopicRouteData.h
similarity index 100%
rename from src/main/cpp/client/include/TopicRouteData.h
rename to cpp/src/main/cpp/client/include/TopicRouteData.h
diff --git a/src/main/cpp/client/mocks/BUILD.bazel b/cpp/src/main/cpp/client/mocks/BUILD.bazel
similarity index 100%
rename from src/main/cpp/client/mocks/BUILD.bazel
rename to cpp/src/main/cpp/client/mocks/BUILD.bazel
diff --git a/src/main/cpp/client/mocks/include/ClientManagerMock.h b/cpp/src/main/cpp/client/mocks/include/ClientManagerMock.h
similarity index 100%
rename from src/main/cpp/client/mocks/include/ClientManagerMock.h
rename to cpp/src/main/cpp/client/mocks/include/ClientManagerMock.h
diff --git a/src/main/cpp/client/mocks/include/ClientMock.h b/cpp/src/main/cpp/client/mocks/include/ClientMock.h
similarity index 100%
rename from src/main/cpp/client/mocks/include/ClientMock.h
rename to cpp/src/main/cpp/client/mocks/include/ClientMock.h
diff --git a/src/main/cpp/client/mocks/include/ReceiveMessageCallbackMock.h b/cpp/src/main/cpp/client/mocks/include/ReceiveMessageCallbackMock.h
similarity index 100%
rename from src/main/cpp/client/mocks/include/ReceiveMessageCallbackMock.h
rename to cpp/src/main/cpp/client/mocks/include/ReceiveMessageCallbackMock.h
diff --git a/src/main/cpp/client/mocks/include/RpcClientMock.h b/cpp/src/main/cpp/client/mocks/include/RpcClientMock.h
similarity index 100%
rename from src/main/cpp/client/mocks/include/RpcClientMock.h
rename to cpp/src/main/cpp/client/mocks/include/RpcClientMock.h
diff --git a/src/main/cpp/concurrent/BUILD.bazel b/cpp/src/main/cpp/concurrent/BUILD.bazel
similarity index 100%
rename from src/main/cpp/concurrent/BUILD.bazel
rename to cpp/src/main/cpp/concurrent/BUILD.bazel
diff --git a/src/main/cpp/concurrent/CountdownLatch.cpp b/cpp/src/main/cpp/concurrent/CountdownLatch.cpp
similarity index 100%
rename from src/main/cpp/concurrent/CountdownLatch.cpp
rename to cpp/src/main/cpp/concurrent/CountdownLatch.cpp
diff --git a/src/main/cpp/concurrent/include/CountdownLatch.h b/cpp/src/main/cpp/concurrent/include/CountdownLatch.h
similarity index 100%
rename from src/main/cpp/concurrent/include/CountdownLatch.h
rename to cpp/src/main/cpp/concurrent/include/CountdownLatch.h
diff --git a/src/main/cpp/log/BUILD.bazel b/cpp/src/main/cpp/log/BUILD.bazel
similarity index 100%
rename from src/main/cpp/log/BUILD.bazel
rename to cpp/src/main/cpp/log/BUILD.bazel
diff --git a/src/main/cpp/log/LoggerImpl.cpp b/cpp/src/main/cpp/log/LoggerImpl.cpp
similarity index 100%
rename from src/main/cpp/log/LoggerImpl.cpp
rename to cpp/src/main/cpp/log/LoggerImpl.cpp
diff --git a/src/main/cpp/log/include/LoggerImpl.h b/cpp/src/main/cpp/log/include/LoggerImpl.h
similarity index 100%
rename from src/main/cpp/log/include/LoggerImpl.h
rename to cpp/src/main/cpp/log/include/LoggerImpl.h
diff --git a/src/main/cpp/remoting/BUILD.bazel b/cpp/src/main/cpp/remoting/BUILD.bazel
similarity index 100%
rename from src/main/cpp/remoting/BUILD.bazel
rename to cpp/src/main/cpp/remoting/BUILD.bazel
diff --git a/src/main/cpp/remoting/BrokerData.cpp b/cpp/src/main/cpp/remoting/BrokerData.cpp
similarity index 100%
rename from src/main/cpp/remoting/BrokerData.cpp
rename to cpp/src/main/cpp/remoting/BrokerData.cpp
diff --git a/src/main/cpp/remoting/QueryRouteRequestHeader.cpp b/cpp/src/main/cpp/remoting/QueryRouteRequestHeader.cpp
similarity index 100%
rename from src/main/cpp/remoting/QueryRouteRequestHeader.cpp
rename to cpp/src/main/cpp/remoting/QueryRouteRequestHeader.cpp
diff --git a/src/main/cpp/remoting/QueueData.cpp b/cpp/src/main/cpp/remoting/QueueData.cpp
similarity index 100%
rename from src/main/cpp/remoting/QueueData.cpp
rename to cpp/src/main/cpp/remoting/QueueData.cpp
diff --git a/src/main/cpp/remoting/RemotingCommand.cpp b/cpp/src/main/cpp/remoting/RemotingCommand.cpp
similarity index 100%
rename from src/main/cpp/remoting/RemotingCommand.cpp
rename to cpp/src/main/cpp/remoting/RemotingCommand.cpp
diff --git a/src/main/cpp/remoting/TopicRouteData.cpp b/cpp/src/main/cpp/remoting/TopicRouteData.cpp
similarity index 100%
rename from src/main/cpp/remoting/TopicRouteData.cpp
rename to cpp/src/main/cpp/remoting/TopicRouteData.cpp
diff --git a/src/main/cpp/remoting/include/BrokerData.h b/cpp/src/main/cpp/remoting/include/BrokerData.h
similarity index 100%
rename from src/main/cpp/remoting/include/BrokerData.h
rename to cpp/src/main/cpp/remoting/include/BrokerData.h
diff --git a/src/main/cpp/remoting/include/CommandCustomHeader.h b/cpp/src/main/cpp/remoting/include/CommandCustomHeader.h
similarity index 100%
rename from src/main/cpp/remoting/include/CommandCustomHeader.h
rename to cpp/src/main/cpp/remoting/include/CommandCustomHeader.h
diff --git a/src/main/cpp/remoting/include/LanguageCode.h b/cpp/src/main/cpp/remoting/include/LanguageCode.h
similarity index 100%
rename from src/main/cpp/remoting/include/LanguageCode.h
rename to cpp/src/main/cpp/remoting/include/LanguageCode.h
diff --git a/src/main/cpp/remoting/include/QueryRouteRequestHeader.h b/cpp/src/main/cpp/remoting/include/QueryRouteRequestHeader.h
similarity index 100%
rename from src/main/cpp/remoting/include/QueryRouteRequestHeader.h
rename to cpp/src/main/cpp/remoting/include/QueryRouteRequestHeader.h
diff --git a/src/main/cpp/remoting/include/QueueData.h b/cpp/src/main/cpp/remoting/include/QueueData.h
similarity index 100%
rename from src/main/cpp/remoting/include/QueueData.h
rename to cpp/src/main/cpp/remoting/include/QueueData.h
diff --git a/src/main/cpp/remoting/include/RemotingCommand.h b/cpp/src/main/cpp/remoting/include/RemotingCommand.h
similarity index 100%
rename from src/main/cpp/remoting/include/RemotingCommand.h
rename to cpp/src/main/cpp/remoting/include/RemotingCommand.h
diff --git a/src/main/cpp/remoting/include/RemotingCommandType.h b/cpp/src/main/cpp/remoting/include/RemotingCommandType.h
similarity index 100%
rename from src/main/cpp/remoting/include/RemotingCommandType.h
rename to cpp/src/main/cpp/remoting/include/RemotingCommandType.h
diff --git a/src/main/cpp/remoting/include/RequestCode.h b/cpp/src/main/cpp/remoting/include/RequestCode.h
similarity index 100%
rename from src/main/cpp/remoting/include/RequestCode.h
rename to cpp/src/main/cpp/remoting/include/RequestCode.h
diff --git a/src/main/cpp/remoting/include/ResponseCode.h b/cpp/src/main/cpp/remoting/include/ResponseCode.h
similarity index 100%
rename from src/main/cpp/remoting/include/ResponseCode.h
rename to cpp/src/main/cpp/remoting/include/ResponseCode.h
diff --git a/src/main/cpp/remoting/include/TopicRouteData.h b/cpp/src/main/cpp/remoting/include/TopicRouteData.h
similarity index 100%
rename from src/main/cpp/remoting/include/TopicRouteData.h
rename to cpp/src/main/cpp/remoting/include/TopicRouteData.h
diff --git a/src/main/cpp/remoting/include/Version.h b/cpp/src/main/cpp/remoting/include/Version.h
similarity index 100%
rename from src/main/cpp/remoting/include/Version.h
rename to cpp/src/main/cpp/remoting/include/Version.h
diff --git a/src/main/cpp/rocketmq/AsyncReceiveMessageCallback.cpp b/cpp/src/main/cpp/rocketmq/AsyncReceiveMessageCallback.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/AsyncReceiveMessageCallback.cpp
rename to cpp/src/main/cpp/rocketmq/AsyncReceiveMessageCallback.cpp
diff --git a/src/main/cpp/rocketmq/BUILD.bazel b/cpp/src/main/cpp/rocketmq/BUILD.bazel
similarity index 100%
rename from src/main/cpp/rocketmq/BUILD.bazel
rename to cpp/src/main/cpp/rocketmq/BUILD.bazel
diff --git a/src/main/cpp/rocketmq/ClientImpl.cpp b/cpp/src/main/cpp/rocketmq/ClientImpl.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/ClientImpl.cpp
rename to cpp/src/main/cpp/rocketmq/ClientImpl.cpp
diff --git a/src/main/cpp/rocketmq/ConsumeMessageServiceImpl.cpp b/cpp/src/main/cpp/rocketmq/ConsumeMessageServiceImpl.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/ConsumeMessageServiceImpl.cpp
rename to cpp/src/main/cpp/rocketmq/ConsumeMessageServiceImpl.cpp
diff --git a/src/main/cpp/rocketmq/ConsumeTask.cpp b/cpp/src/main/cpp/rocketmq/ConsumeTask.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/ConsumeTask.cpp
rename to cpp/src/main/cpp/rocketmq/ConsumeTask.cpp
diff --git a/src/main/cpp/rocketmq/DynamicNameServerResolver.cpp b/cpp/src/main/cpp/rocketmq/DynamicNameServerResolver.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/DynamicNameServerResolver.cpp
rename to cpp/src/main/cpp/rocketmq/DynamicNameServerResolver.cpp
diff --git a/src/main/cpp/rocketmq/MessageGroupQueueSelector.cpp b/cpp/src/main/cpp/rocketmq/MessageGroupQueueSelector.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/MessageGroupQueueSelector.cpp
rename to cpp/src/main/cpp/rocketmq/MessageGroupQueueSelector.cpp
diff --git a/src/main/cpp/rocketmq/NamingScheme.cpp b/cpp/src/main/cpp/rocketmq/NamingScheme.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/NamingScheme.cpp
rename to cpp/src/main/cpp/rocketmq/NamingScheme.cpp
diff --git a/src/main/cpp/rocketmq/ProcessQueueImpl.cpp b/cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/ProcessQueueImpl.cpp
rename to cpp/src/main/cpp/rocketmq/ProcessQueueImpl.cpp
diff --git a/src/main/cpp/rocketmq/Producer.cpp b/cpp/src/main/cpp/rocketmq/Producer.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/Producer.cpp
rename to cpp/src/main/cpp/rocketmq/Producer.cpp
diff --git a/src/main/cpp/rocketmq/ProducerImpl.cpp b/cpp/src/main/cpp/rocketmq/ProducerImpl.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/ProducerImpl.cpp
rename to cpp/src/main/cpp/rocketmq/ProducerImpl.cpp
diff --git a/src/main/cpp/rocketmq/PushConsumer.cpp b/cpp/src/main/cpp/rocketmq/PushConsumer.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/PushConsumer.cpp
rename to cpp/src/main/cpp/rocketmq/PushConsumer.cpp
diff --git a/src/main/cpp/rocketmq/PushConsumerImpl.cpp b/cpp/src/main/cpp/rocketmq/PushConsumerImpl.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/PushConsumerImpl.cpp
rename to cpp/src/main/cpp/rocketmq/PushConsumerImpl.cpp
diff --git a/src/main/cpp/rocketmq/SendContext.cpp b/cpp/src/main/cpp/rocketmq/SendContext.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/SendContext.cpp
rename to cpp/src/main/cpp/rocketmq/SendContext.cpp
diff --git a/src/main/cpp/rocketmq/SimpleConsumer.cpp b/cpp/src/main/cpp/rocketmq/SimpleConsumer.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/SimpleConsumer.cpp
rename to cpp/src/main/cpp/rocketmq/SimpleConsumer.cpp
diff --git a/src/main/cpp/rocketmq/SimpleConsumerImpl.cpp b/cpp/src/main/cpp/rocketmq/SimpleConsumerImpl.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/SimpleConsumerImpl.cpp
rename to cpp/src/main/cpp/rocketmq/SimpleConsumerImpl.cpp
diff --git a/src/main/cpp/rocketmq/StaticNameServerResolver.cpp b/cpp/src/main/cpp/rocketmq/StaticNameServerResolver.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/StaticNameServerResolver.cpp
rename to cpp/src/main/cpp/rocketmq/StaticNameServerResolver.cpp
diff --git a/src/main/cpp/rocketmq/TopicPublishInfo.cpp b/cpp/src/main/cpp/rocketmq/TopicPublishInfo.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/TopicPublishInfo.cpp
rename to cpp/src/main/cpp/rocketmq/TopicPublishInfo.cpp
diff --git a/src/main/cpp/rocketmq/TransactionImpl.cpp b/cpp/src/main/cpp/rocketmq/TransactionImpl.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/TransactionImpl.cpp
rename to cpp/src/main/cpp/rocketmq/TransactionImpl.cpp
diff --git a/src/main/cpp/rocketmq/include/AsyncReceiveMessageCallback.h b/cpp/src/main/cpp/rocketmq/include/AsyncReceiveMessageCallback.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/AsyncReceiveMessageCallback.h
rename to cpp/src/main/cpp/rocketmq/include/AsyncReceiveMessageCallback.h
diff --git a/src/main/cpp/rocketmq/include/ClientImpl.h b/cpp/src/main/cpp/rocketmq/include/ClientImpl.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/ClientImpl.h
rename to cpp/src/main/cpp/rocketmq/include/ClientImpl.h
diff --git a/src/main/cpp/rocketmq/include/ClientResourceBundle.h b/cpp/src/main/cpp/rocketmq/include/ClientResourceBundle.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/ClientResourceBundle.h
rename to cpp/src/main/cpp/rocketmq/include/ClientResourceBundle.h
diff --git a/src/main/cpp/rocketmq/include/ConsumeMessageService.h b/cpp/src/main/cpp/rocketmq/include/ConsumeMessageService.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/ConsumeMessageService.h
rename to cpp/src/main/cpp/rocketmq/include/ConsumeMessageService.h
diff --git a/src/main/cpp/rocketmq/include/ConsumeMessageServiceImpl.h b/cpp/src/main/cpp/rocketmq/include/ConsumeMessageServiceImpl.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/ConsumeMessageServiceImpl.h
rename to cpp/src/main/cpp/rocketmq/include/ConsumeMessageServiceImpl.h
diff --git a/src/main/cpp/rocketmq/include/ConsumeTask.h b/cpp/src/main/cpp/rocketmq/include/ConsumeTask.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/ConsumeTask.h
rename to cpp/src/main/cpp/rocketmq/include/ConsumeTask.h
diff --git a/src/main/cpp/rocketmq/include/Consumer.h b/cpp/src/main/cpp/rocketmq/include/Consumer.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/Consumer.h
rename to cpp/src/main/cpp/rocketmq/include/Consumer.h
diff --git a/src/main/cpp/rocketmq/include/DynamicNameServerResolver.h b/cpp/src/main/cpp/rocketmq/include/DynamicNameServerResolver.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/DynamicNameServerResolver.h
rename to cpp/src/main/cpp/rocketmq/include/DynamicNameServerResolver.h
diff --git a/src/main/cpp/rocketmq/include/MessageGroupQueueSelector.h b/cpp/src/main/cpp/rocketmq/include/MessageGroupQueueSelector.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/MessageGroupQueueSelector.h
rename to cpp/src/main/cpp/rocketmq/include/MessageGroupQueueSelector.h
diff --git a/src/main/cpp/rocketmq/include/NameServerResolver.h b/cpp/src/main/cpp/rocketmq/include/NameServerResolver.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/NameServerResolver.h
rename to cpp/src/main/cpp/rocketmq/include/NameServerResolver.h
diff --git a/src/main/cpp/rocketmq/include/NamingScheme.h b/cpp/src/main/cpp/rocketmq/include/NamingScheme.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/NamingScheme.h
rename to cpp/src/main/cpp/rocketmq/include/NamingScheme.h
diff --git a/src/main/cpp/rocketmq/include/ProcessQueue.h b/cpp/src/main/cpp/rocketmq/include/ProcessQueue.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/ProcessQueue.h
rename to cpp/src/main/cpp/rocketmq/include/ProcessQueue.h
diff --git a/src/main/cpp/rocketmq/include/ProcessQueueImpl.h b/cpp/src/main/cpp/rocketmq/include/ProcessQueueImpl.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/ProcessQueueImpl.h
rename to cpp/src/main/cpp/rocketmq/include/ProcessQueueImpl.h
diff --git a/src/main/cpp/rocketmq/include/ProducerImpl.h b/cpp/src/main/cpp/rocketmq/include/ProducerImpl.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/ProducerImpl.h
rename to cpp/src/main/cpp/rocketmq/include/ProducerImpl.h
diff --git a/src/main/cpp/rocketmq/include/PublishInfoCallback.h b/cpp/src/main/cpp/rocketmq/include/PublishInfoCallback.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/PublishInfoCallback.h
rename to cpp/src/main/cpp/rocketmq/include/PublishInfoCallback.h
diff --git a/src/main/cpp/rocketmq/include/PushConsumerImpl.h b/cpp/src/main/cpp/rocketmq/include/PushConsumerImpl.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/PushConsumerImpl.h
rename to cpp/src/main/cpp/rocketmq/include/PushConsumerImpl.h
diff --git a/src/main/cpp/rocketmq/include/SendContext.h b/cpp/src/main/cpp/rocketmq/include/SendContext.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/SendContext.h
rename to cpp/src/main/cpp/rocketmq/include/SendContext.h
diff --git a/src/main/cpp/rocketmq/include/SimpleConsumerImpl.h b/cpp/src/main/cpp/rocketmq/include/SimpleConsumerImpl.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/SimpleConsumerImpl.h
rename to cpp/src/main/cpp/rocketmq/include/SimpleConsumerImpl.h
diff --git a/src/main/cpp/rocketmq/include/StaticNameServerResolver.h b/cpp/src/main/cpp/rocketmq/include/StaticNameServerResolver.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/StaticNameServerResolver.h
rename to cpp/src/main/cpp/rocketmq/include/StaticNameServerResolver.h
diff --git a/src/main/cpp/rocketmq/include/TopicPublishInfo.h b/cpp/src/main/cpp/rocketmq/include/TopicPublishInfo.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/TopicPublishInfo.h
rename to cpp/src/main/cpp/rocketmq/include/TopicPublishInfo.h
diff --git a/src/main/cpp/rocketmq/include/TransactionImpl.h b/cpp/src/main/cpp/rocketmq/include/TransactionImpl.h
similarity index 100%
rename from src/main/cpp/rocketmq/include/TransactionImpl.h
rename to cpp/src/main/cpp/rocketmq/include/TransactionImpl.h
diff --git a/src/main/cpp/rocketmq/mocks/BUILD.bazel b/cpp/src/main/cpp/rocketmq/mocks/BUILD.bazel
similarity index 100%
rename from src/main/cpp/rocketmq/mocks/BUILD.bazel
rename to cpp/src/main/cpp/rocketmq/mocks/BUILD.bazel
diff --git a/src/main/cpp/rocketmq/mocks/include/ConsumeMessageServiceMock.h b/cpp/src/main/cpp/rocketmq/mocks/include/ConsumeMessageServiceMock.h
similarity index 100%
rename from src/main/cpp/rocketmq/mocks/include/ConsumeMessageServiceMock.h
rename to cpp/src/main/cpp/rocketmq/mocks/include/ConsumeMessageServiceMock.h
diff --git a/src/main/cpp/rocketmq/mocks/include/ConsumerMock.h b/cpp/src/main/cpp/rocketmq/mocks/include/ConsumerMock.h
similarity index 100%
rename from src/main/cpp/rocketmq/mocks/include/ConsumerMock.h
rename to cpp/src/main/cpp/rocketmq/mocks/include/ConsumerMock.h
diff --git a/src/main/cpp/rocketmq/mocks/include/NameServerResolverMock.h b/cpp/src/main/cpp/rocketmq/mocks/include/NameServerResolverMock.h
similarity index 100%
rename from src/main/cpp/rocketmq/mocks/include/NameServerResolverMock.h
rename to cpp/src/main/cpp/rocketmq/mocks/include/NameServerResolverMock.h
diff --git a/src/main/cpp/rocketmq/mocks/include/ProcessQueueMock.h b/cpp/src/main/cpp/rocketmq/mocks/include/ProcessQueueMock.h
similarity index 100%
rename from src/main/cpp/rocketmq/mocks/include/ProcessQueueMock.h
rename to cpp/src/main/cpp/rocketmq/mocks/include/ProcessQueueMock.h
diff --git a/src/main/cpp/rocketmq/mocks/include/PushConsumerMock.h b/cpp/src/main/cpp/rocketmq/mocks/include/PushConsumerMock.h
similarity index 100%
rename from src/main/cpp/rocketmq/mocks/include/PushConsumerMock.h
rename to cpp/src/main/cpp/rocketmq/mocks/include/PushConsumerMock.h
diff --git a/src/main/cpp/rocketmq/tests/BUILD.bazel b/cpp/src/main/cpp/rocketmq/tests/BUILD.bazel
similarity index 100%
rename from src/main/cpp/rocketmq/tests/BUILD.bazel
rename to cpp/src/main/cpp/rocketmq/tests/BUILD.bazel
diff --git a/src/main/cpp/rocketmq/tests/SendContextTest.cpp b/cpp/src/main/cpp/rocketmq/tests/SendContextTest.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/tests/SendContextTest.cpp
rename to cpp/src/main/cpp/rocketmq/tests/SendContextTest.cpp
diff --git a/src/main/cpp/rocketmq/tests/TimeTest.cpp b/cpp/src/main/cpp/rocketmq/tests/TimeTest.cpp
similarity index 100%
rename from src/main/cpp/rocketmq/tests/TimeTest.cpp
rename to cpp/src/main/cpp/rocketmq/tests/TimeTest.cpp
diff --git a/src/main/cpp/scheduler/BUILD.bazel b/cpp/src/main/cpp/scheduler/BUILD.bazel
similarity index 100%
rename from src/main/cpp/scheduler/BUILD.bazel
rename to cpp/src/main/cpp/scheduler/BUILD.bazel
diff --git a/src/main/cpp/scheduler/SchedulerImpl.cpp b/cpp/src/main/cpp/scheduler/SchedulerImpl.cpp
similarity index 100%
rename from src/main/cpp/scheduler/SchedulerImpl.cpp
rename to cpp/src/main/cpp/scheduler/SchedulerImpl.cpp
diff --git a/src/main/cpp/scheduler/include/Scheduler.h b/cpp/src/main/cpp/scheduler/include/Scheduler.h
similarity index 100%
rename from src/main/cpp/scheduler/include/Scheduler.h
rename to cpp/src/main/cpp/scheduler/include/Scheduler.h
diff --git a/src/main/cpp/scheduler/include/SchedulerImpl.h b/cpp/src/main/cpp/scheduler/include/SchedulerImpl.h
similarity index 100%
rename from src/main/cpp/scheduler/include/SchedulerImpl.h
rename to cpp/src/main/cpp/scheduler/include/SchedulerImpl.h
diff --git a/src/main/cpp/stats/BUILD.bazel b/cpp/src/main/cpp/stats/BUILD.bazel
similarity index 100%
rename from src/main/cpp/stats/BUILD.bazel
rename to cpp/src/main/cpp/stats/BUILD.bazel
diff --git a/src/main/cpp/stats/ConsumeStats.cpp b/cpp/src/main/cpp/stats/ConsumeStats.cpp
similarity index 100%
rename from src/main/cpp/stats/ConsumeStats.cpp
rename to cpp/src/main/cpp/stats/ConsumeStats.cpp
diff --git a/src/main/cpp/stats/MetricBidiReactor.cpp b/cpp/src/main/cpp/stats/MetricBidiReactor.cpp
similarity index 100%
rename from src/main/cpp/stats/MetricBidiReactor.cpp
rename to cpp/src/main/cpp/stats/MetricBidiReactor.cpp
diff --git a/src/main/cpp/stats/OpencensusExporter.cpp b/cpp/src/main/cpp/stats/OpencensusExporter.cpp
similarity index 100%
rename from src/main/cpp/stats/OpencensusExporter.cpp
rename to cpp/src/main/cpp/stats/OpencensusExporter.cpp
diff --git a/src/main/cpp/stats/PublishStats.cpp b/cpp/src/main/cpp/stats/PublishStats.cpp
similarity index 100%
rename from src/main/cpp/stats/PublishStats.cpp
rename to cpp/src/main/cpp/stats/PublishStats.cpp
diff --git a/src/main/cpp/stats/Tag.cpp b/cpp/src/main/cpp/stats/Tag.cpp
similarity index 100%
rename from src/main/cpp/stats/Tag.cpp
rename to cpp/src/main/cpp/stats/Tag.cpp
diff --git a/src/main/cpp/stats/include/ConsumeStats.h b/cpp/src/main/cpp/stats/include/ConsumeStats.h
similarity index 100%
rename from src/main/cpp/stats/include/ConsumeStats.h
rename to cpp/src/main/cpp/stats/include/ConsumeStats.h
diff --git a/src/main/cpp/stats/include/Exporter.h b/cpp/src/main/cpp/stats/include/Exporter.h
similarity index 100%
rename from src/main/cpp/stats/include/Exporter.h
rename to cpp/src/main/cpp/stats/include/Exporter.h
diff --git a/src/main/cpp/stats/include/MetricBidiReactor.h b/cpp/src/main/cpp/stats/include/MetricBidiReactor.h
similarity index 100%
rename from src/main/cpp/stats/include/MetricBidiReactor.h
rename to cpp/src/main/cpp/stats/include/MetricBidiReactor.h
diff --git a/src/main/cpp/stats/include/OpencensusExporter.h b/cpp/src/main/cpp/stats/include/OpencensusExporter.h
similarity index 100%
rename from src/main/cpp/stats/include/OpencensusExporter.h
rename to cpp/src/main/cpp/stats/include/OpencensusExporter.h
diff --git a/src/main/cpp/stats/include/PublishStats.h b/cpp/src/main/cpp/stats/include/PublishStats.h
similarity index 100%
rename from src/main/cpp/stats/include/PublishStats.h
rename to cpp/src/main/cpp/stats/include/PublishStats.h
diff --git a/src/main/cpp/stats/include/Tag.h b/cpp/src/main/cpp/stats/include/Tag.h
similarity index 100%
rename from src/main/cpp/stats/include/Tag.h
rename to cpp/src/main/cpp/stats/include/Tag.h
diff --git a/src/main/cpp/stats/tests/BUILD.bazel b/cpp/src/main/cpp/stats/tests/BUILD.bazel
similarity index 100%
rename from src/main/cpp/stats/tests/BUILD.bazel
rename to cpp/src/main/cpp/stats/tests/BUILD.bazel
diff --git a/src/main/cpp/stats/tests/PublishStatsTest.cpp b/cpp/src/main/cpp/stats/tests/PublishStatsTest.cpp
similarity index 100%
rename from src/main/cpp/stats/tests/PublishStatsTest.cpp
rename to cpp/src/main/cpp/stats/tests/PublishStatsTest.cpp
diff --git a/src/main/cpp/trace/BUILD.bazel b/cpp/src/main/cpp/trace/BUILD.bazel
similarity index 100%
rename from src/main/cpp/trace/BUILD.bazel
rename to cpp/src/main/cpp/trace/BUILD.bazel
diff --git a/src/main/cpp/trace/TracingUtility.cpp b/cpp/src/main/cpp/trace/TracingUtility.cpp
similarity index 100%
rename from src/main/cpp/trace/TracingUtility.cpp
rename to cpp/src/main/cpp/trace/TracingUtility.cpp
diff --git a/src/main/cpp/trace/include/TracingUtility.h b/cpp/src/main/cpp/trace/include/TracingUtility.h
similarity index 100%
rename from src/main/cpp/trace/include/TracingUtility.h
rename to cpp/src/main/cpp/trace/include/TracingUtility.h
diff --git a/third_party/BUILD.bazel b/cpp/third_party/BUILD.bazel
similarity index 100%
rename from third_party/BUILD.bazel
rename to cpp/third_party/BUILD.bazel
diff --git a/third_party/ThreadPool.BUILD b/cpp/third_party/ThreadPool.BUILD
similarity index 100%
rename from third_party/ThreadPool.BUILD
rename to cpp/third_party/ThreadPool.BUILD
diff --git a/third_party/asio.BUILD b/cpp/third_party/asio.BUILD
similarity index 100%
rename from third_party/asio.BUILD
rename to cpp/third_party/asio.BUILD
diff --git a/third_party/cpp_httplib.BUILD b/cpp/third_party/cpp_httplib.BUILD
similarity index 100%
rename from third_party/cpp_httplib.BUILD
rename to cpp/third_party/cpp_httplib.BUILD
diff --git a/third_party/curl.BUILD b/cpp/third_party/curl.BUILD
similarity index 100%
rename from third_party/curl.BUILD
rename to cpp/third_party/curl.BUILD
diff --git a/third_party/filesystem.BUILD b/cpp/third_party/filesystem.BUILD
similarity index 100%
rename from third_party/filesystem.BUILD
rename to cpp/third_party/filesystem.BUILD
diff --git a/third_party/fmtlib.BUILD b/cpp/third_party/fmtlib.BUILD
similarity index 100%
rename from third_party/fmtlib.BUILD
rename to cpp/third_party/fmtlib.BUILD
diff --git a/third_party/spdlog.BUILD b/cpp/third_party/spdlog.BUILD
similarity index 100%
rename from third_party/spdlog.BUILD
rename to cpp/third_party/spdlog.BUILD
diff --git a/tools/copyright.txt b/cpp/tools/copyright.txt
similarity index 100%
rename from tools/copyright.txt
rename to cpp/tools/copyright.txt
diff --git a/tools/coverage.sh b/cpp/tools/coverage.sh
similarity index 100%
rename from tools/coverage.sh
rename to cpp/tools/coverage.sh
diff --git a/tools/fix_copyright.py b/cpp/tools/fix_copyright.py
similarity index 100%
rename from tools/fix_copyright.py
rename to cpp/tools/fix_copyright.py
diff --git a/tools/format.sh b/cpp/tools/format.sh
similarity index 100%
rename from tools/format.sh
rename to cpp/tools/format.sh
diff --git a/tools/trouble_shooting.sh b/cpp/tools/trouble_shooting.sh
similarity index 100%
rename from tools/trouble_shooting.sh
rename to cpp/tools/trouble_shooting.sh
diff --git a/tools/use_clang.sh b/cpp/tools/use_clang.sh
similarity index 100%
rename from tools/use_clang.sh
rename to cpp/tools/use_clang.sh

[rocketmq-clients] 03/06: Merge branch 'main' into clients

Posted by aa...@apache.org.
This is an automated email from the ASF dual-hosted git repository.

aaronai pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git

commit da9da5bbd98efc81ad1eb524430374add69397eb
Merge: 515c9db 68f6fd2
Author: 凌楚 <ya...@alibaba-inc.com>
AuthorDate: Fri Jun 17 18:26:11 2022 +0800

    Merge branch 'main' into clients

 .github/workflows/main.yml                         |   36 +
 .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 +
 276 files changed, 22701 insertions(+)