You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by li...@apache.org on 2022/09/27 03:51:43 UTC
[rocketmq-clients] branch container created (now f3f2591)
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a change to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
at f3f2591 Fill as many fields as possible for Settings#Publishing
This branch includes the following new commits:
new 0545985 Provide image
new 6dac851 Prpare cc_image_repos()
new f100e51 Use alpine base image
new 32bf289 Debug
new 44818b4 Add container push
new 00e1a85 Change registry
new c6f4e63 Revert registry to docker.io
new be7c29f Use ubuntu:18.04 as base image
new 3729688 Use latest ubuntu
new abc14f9 Remove target name override
new f3f2591 Fill as many fields as possible for Settings#Publishing
The 11 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.
[rocketmq-clients] 11/11: Fill as many fields as possible for Settings#Publishing
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit f3f25916b5277916ed5c4c975b6c842658de8afe
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 15:18:11 2022 +0800
Fill as many fields as possible for Settings#Publishing
---
cpp/source/rocketmq/ProducerImpl.cpp | 6 +++++-
1 file changed, 5 insertions(+), 1 deletion(-)
diff --git a/cpp/source/rocketmq/ProducerImpl.cpp b/cpp/source/rocketmq/ProducerImpl.cpp
index 7ad127c..2029d39 100644
--- a/cpp/source/rocketmq/ProducerImpl.cpp
+++ b/cpp/source/rocketmq/ProducerImpl.cpp
@@ -581,7 +581,11 @@ void ProducerImpl::topicsOfInterest(std::vector<std::string> topics) {
void ProducerImpl::buildClientSettings(rmq::Settings& settings) {
settings.set_client_type(rmq::ClientType::PRODUCER);
- auto topics = settings.mutable_publishing()->mutable_topics();
+ auto publishing_setting = settings.mutable_publishing();
+ publishing_setting->set_validate_message_type(false);
+ publishing_setting->set_max_body_size(MixAll::MAX_MESSAGE_BODY_SIZE);
+
+ auto topics = publishing_setting->mutable_topics();
{
absl::MutexLock lk(&topics_mtx_);
for (const auto& item : topics_) {
[rocketmq-clients] 10/11: Remove target name override
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit abc14f989e33b8de63fb3590168f31bd00da6ca5
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 14:51:41 2022 +0800
Remove target name override
---
cpp/source/client/ClientManagerImpl.cpp | 2 --
1 file changed, 2 deletions(-)
diff --git a/cpp/source/client/ClientManagerImpl.cpp b/cpp/source/client/ClientManagerImpl.cpp
index a39bb73..d81c490 100644
--- a/cpp/source/client/ClientManagerImpl.cpp
+++ b/cpp/source/client/ClientManagerImpl.cpp
@@ -81,8 +81,6 @@ ClientManagerImpl::ClientManagerImpl(std::string resource_namespace)
*/
channel_arguments_.SetInt(GRPC_ARG_ENABLE_RETRIES, 0);
- channel_arguments_.SetSslTargetNameOverride("localhost");
-
SPDLOG_INFO("ClientManager[ResourceNamespace={}] created", resource_namespace_);
}
[rocketmq-clients] 03/11: Use alpine base image
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit f100e51a0bc51a4e4726ffec3430b11c176344f5
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 13:23:46 2022 +0800
Use alpine base image
---
cpp/examples/BUILD.bazel | 18 ++++++++++++++++++
1 file changed, 18 insertions(+)
diff --git a/cpp/examples/BUILD.bazel b/cpp/examples/BUILD.bazel
index fb9b392..2959b66 100644
--- a/cpp/examples/BUILD.bazel
+++ b/cpp/examples/BUILD.bazel
@@ -16,6 +16,7 @@
#
load("@rules_cc//cc:defs.bzl", "cc_binary")
load("@io_bazel_rules_docker//cc:image.bzl", "cc_image")
+load("@io_bazel_rules_docker//container:container.bzl", "container_pull", "container_image")
cc_binary(
name = "example_producer",
@@ -28,6 +29,22 @@ cc_binary(
],
)
+container_pull(
+ name = "alpine",
+ registry = "index.docker.io",
+ repository = "library/alpine",
+ tag = "3.8",
+)
+
+container_image(
+ name = "base_image",
+ base = "alpine",
+ env = {
+ "GRPC_VERBOSITY": "debug",
+ "GRPC_TRACE": "tcp,http,api",
+ },
+)
+
cc_image(
name = "container_example_producer",
srcs = [
@@ -37,6 +54,7 @@ cc_image(
"//source/rocketmq:rocketmq_library",
"@com_github_gflags_gflags//:gflags",
],
+ base = ":base_image",
)
cc_binary(
[rocketmq-clients] 02/11: Prpare cc_image_repos()
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 6dac85184386446e5dbb2654c75ea80f2e2b08cd
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 12:59:31 2022 +0800
Prpare cc_image_repos()
---
cpp/WORKSPACE | 3 +++
1 file changed, 3 insertions(+)
diff --git a/cpp/WORKSPACE b/cpp/WORKSPACE
index 178617a..a2472b6 100644
--- a/cpp/WORKSPACE
+++ b/cpp/WORKSPACE
@@ -24,6 +24,9 @@ container_repositories()
load("@io_bazel_rules_docker//repositories:deps.bzl", container_deps = "deps")
container_deps()
+load("@io_bazel_rules_docker//cc:image.bzl", cc_image_repos = "repositories")
+cc_image_repos()
+
# Support Bazel RBE(remote build execution)
load("@bazel_tools//tools/build_defs/repo:http.bzl", "http_archive")
http_archive(
[rocketmq-clients] 08/11: Use ubuntu:18.04 as base image
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit be7c29f543a9dede11f219452311e7693890f2bc
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 14:04:14 2022 +0800
Use ubuntu:18.04 as base image
---
cpp/WORKSPACE | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/cpp/WORKSPACE b/cpp/WORKSPACE
index 190b061..8e808dd 100644
--- a/cpp/WORKSPACE
+++ b/cpp/WORKSPACE
@@ -30,8 +30,8 @@ load("@io_bazel_rules_docker//container:container.bzl", "container_pull")
container_pull(
name = "cc_base",
registry = "index.docker.io",
- repository = "library/alpine",
- tag = "3.8",
+ repository = "ubuntu",
+ tag = "18.04",
)
# Support Bazel RBE(remote build execution)
[rocketmq-clients] 09/11: Use latest ubuntu
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 3729688b831566d52dc5ad6949347e6f17214acb
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 14:07:13 2022 +0800
Use latest ubuntu
---
cpp/WORKSPACE | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/cpp/WORKSPACE b/cpp/WORKSPACE
index 8e808dd..975bc94 100644
--- a/cpp/WORKSPACE
+++ b/cpp/WORKSPACE
@@ -31,7 +31,7 @@ container_pull(
name = "cc_base",
registry = "index.docker.io",
repository = "ubuntu",
- tag = "18.04",
+ tag = "22.04",
)
# Support Bazel RBE(remote build execution)
[rocketmq-clients] 06/11: Change registry
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 00e1a850c28df7f1d5083e463217b1313eace0d6
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 13:50:15 2022 +0800
Change registry
---
cpp/examples/BUILD.bazel | 3 +--
1 file changed, 1 insertion(+), 2 deletions(-)
diff --git a/cpp/examples/BUILD.bazel b/cpp/examples/BUILD.bazel
index 9f3d90a..8cad6be 100644
--- a/cpp/examples/BUILD.bazel
+++ b/cpp/examples/BUILD.bazel
@@ -54,9 +54,8 @@ container_push(
name = "push_example_producer_container",
format = "Docker",
image = ":container_example_producer",
- registry = "docker.io",
+ registry = "hub.docker.com",
repository = "lizhanhui/sdk5",
- windows_paths = False,
)
cc_binary(
[rocketmq-clients] 01/11: Provide image
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 05459851b7ec97982474f1d5df307e999d21ca1d
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 12:52:29 2022 +0800
Provide image
---
cpp/WORKSPACE | 8 ++++++++
cpp/bazel/rocketmq_deps.bzl | 10 ++++++++++
cpp/examples/BUILD.bazel | 12 ++++++++++++
3 files changed, 30 insertions(+)
diff --git a/cpp/WORKSPACE b/cpp/WORKSPACE
index d09dd44..178617a 100644
--- a/cpp/WORKSPACE
+++ b/cpp/WORKSPACE
@@ -16,6 +16,14 @@ load("@rules_proto//proto:repositories.bzl", "rules_proto_dependencies", "rules_
rules_proto_dependencies()
rules_proto_toolchains()
+load(
+ "@io_bazel_rules_docker//repositories:repositories.bzl",
+ container_repositories = "repositories",
+)
+container_repositories()
+load("@io_bazel_rules_docker//repositories:deps.bzl", container_deps = "deps")
+container_deps()
+
# Support Bazel RBE(remote build execution)
load("@bazel_tools//tools/build_defs/repo:http.bzl", "http_archive")
http_archive(
diff --git a/cpp/bazel/rocketmq_deps.bzl b/cpp/bazel/rocketmq_deps.bzl
index eae31a6..b70cbc0 100644
--- a/cpp/bazel/rocketmq_deps.bzl
+++ b/cpp/bazel/rocketmq_deps.bzl
@@ -188,3 +188,13 @@ def rocketmq_deps():
"https://github.com/bazelbuild/rules_proto/archive/refs/tags/4.0.0-3.20.0.tar.gz",
],
)
+
+ maybe(
+ http_archive,
+ name = "io_bazel_rules_docker",
+ sha256 = "b1e80761a8a8243d03ebca8845e9cc1ba6c82ce7c5179ce2b295cd36f7e394bf",
+ urls = [
+ "https://shutian.oss-cn-hangzhou.aliyuncs.com/cdn/rules_docker/rules_docker-v0.25.0.tar.gz",
+ "https://github.com/bazelbuild/rules_docker/releases/download/v0.25.0/rules_docker-v0.25.0.tar.gz",
+ ],
+ )
diff --git a/cpp/examples/BUILD.bazel b/cpp/examples/BUILD.bazel
index 5113e15..fb9b392 100644
--- a/cpp/examples/BUILD.bazel
+++ b/cpp/examples/BUILD.bazel
@@ -15,6 +15,7 @@
# limitations under the License.
#
load("@rules_cc//cc:defs.bzl", "cc_binary")
+load("@io_bazel_rules_docker//cc:image.bzl", "cc_image")
cc_binary(
name = "example_producer",
@@ -27,6 +28,17 @@ cc_binary(
],
)
+cc_image(
+ name = "container_example_producer",
+ srcs = [
+ "ExampleProducer.cpp",
+ ],
+ deps = [
+ "//source/rocketmq:rocketmq_library",
+ "@com_github_gflags_gflags//:gflags",
+ ],
+)
+
cc_binary(
name = "example_producer_with_fifo_message",
srcs = [
[rocketmq-clients] 05/11: Add container push
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 44818b4fdad4ac180c15f14fc222f9a415b04923
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 13:43:46 2022 +0800
Add container push
---
cpp/examples/BUILD.bazel | 11 ++++++++++-
1 file changed, 10 insertions(+), 1 deletion(-)
diff --git a/cpp/examples/BUILD.bazel b/cpp/examples/BUILD.bazel
index 0d4436b..9f3d90a 100644
--- a/cpp/examples/BUILD.bazel
+++ b/cpp/examples/BUILD.bazel
@@ -16,7 +16,7 @@
#
load("@rules_cc//cc:defs.bzl", "cc_binary")
load("@io_bazel_rules_docker//cc:image.bzl", "cc_image")
-load("@io_bazel_rules_docker//container:container.bzl", "container_image")
+load("@io_bazel_rules_docker//container:container.bzl", "container_image", "container_push")
cc_binary(
name = "example_producer",
@@ -50,6 +50,15 @@ cc_image(
base = ":base_image",
)
+container_push(
+ name = "push_example_producer_container",
+ format = "Docker",
+ image = ":container_example_producer",
+ registry = "docker.io",
+ repository = "lizhanhui/sdk5",
+ windows_paths = False,
+)
+
cc_binary(
name = "example_producer_with_fifo_message",
srcs = [
[rocketmq-clients] 04/11: Debug
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit 32bf2891034cae6b5fa1eab131ff5ea9f25bcb7f
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 13:26:50 2022 +0800
Debug
---
cpp/WORKSPACE | 7 +++++++
cpp/examples/BUILD.bazel | 11 ++---------
2 files changed, 9 insertions(+), 9 deletions(-)
diff --git a/cpp/WORKSPACE b/cpp/WORKSPACE
index a2472b6..190b061 100644
--- a/cpp/WORKSPACE
+++ b/cpp/WORKSPACE
@@ -26,6 +26,13 @@ container_deps()
load("@io_bazel_rules_docker//cc:image.bzl", cc_image_repos = "repositories")
cc_image_repos()
+load("@io_bazel_rules_docker//container:container.bzl", "container_pull")
+container_pull(
+ name = "cc_base",
+ registry = "index.docker.io",
+ repository = "library/alpine",
+ tag = "3.8",
+)
# Support Bazel RBE(remote build execution)
load("@bazel_tools//tools/build_defs/repo:http.bzl", "http_archive")
diff --git a/cpp/examples/BUILD.bazel b/cpp/examples/BUILD.bazel
index 2959b66..0d4436b 100644
--- a/cpp/examples/BUILD.bazel
+++ b/cpp/examples/BUILD.bazel
@@ -16,7 +16,7 @@
#
load("@rules_cc//cc:defs.bzl", "cc_binary")
load("@io_bazel_rules_docker//cc:image.bzl", "cc_image")
-load("@io_bazel_rules_docker//container:container.bzl", "container_pull", "container_image")
+load("@io_bazel_rules_docker//container:container.bzl", "container_image")
cc_binary(
name = "example_producer",
@@ -29,16 +29,9 @@ cc_binary(
],
)
-container_pull(
- name = "alpine",
- registry = "index.docker.io",
- repository = "library/alpine",
- tag = "3.8",
-)
-
container_image(
name = "base_image",
- base = "alpine",
+ base = "@cc_base//image",
env = {
"GRPC_VERBOSITY": "debug",
"GRPC_TRACE": "tcp,http,api",
[rocketmq-clients] 07/11: Revert registry to docker.io
Posted by li...@apache.org.
This is an automated email from the ASF dual-hosted git repository.
lizhanhui pushed a commit to branch container
in repository https://gitbox.apache.org/repos/asf/rocketmq-clients.git
commit c6f4e63561b29872e18d2820719932fd9ba4f3ff
Author: Zhanhui Li <li...@apache.org>
AuthorDate: Fri Sep 23 13:51:53 2022 +0800
Revert registry to docker.io
---
cpp/examples/BUILD.bazel | 2 +-
1 file changed, 1 insertion(+), 1 deletion(-)
diff --git a/cpp/examples/BUILD.bazel b/cpp/examples/BUILD.bazel
index 8cad6be..50325e1 100644
--- a/cpp/examples/BUILD.bazel
+++ b/cpp/examples/BUILD.bazel
@@ -54,7 +54,7 @@ container_push(
name = "push_example_producer_container",
format = "Docker",
image = ":container_example_producer",
- registry = "hub.docker.com",
+ registry = "docker.io",
repository = "lizhanhui/sdk5",
)