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 2021/10/20 02:10:58 UTC

[rocketmq-client-cpp] branch main updated: Fix log

This is an automated email from the ASF dual-hosted git repository.

lizhanhui pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/rocketmq-client-cpp.git


The following commit(s) were added to refs/heads/main by this push:
     new d515ca5  Fix log
d515ca5 is described below

commit d515ca50947b994d4e750c57d2f1581ae3c9830c
Author: Li Zhanhui <li...@gmail.com>
AuthorDate: Wed Oct 20 02:10:48 2021 +0000

    Fix log
---
 src/main/cpp/rocketmq/ClientImpl.cpp | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/main/cpp/rocketmq/ClientImpl.cpp b/src/main/cpp/rocketmq/ClientImpl.cpp
index 0bc2205..7996f03 100644
--- a/src/main/cpp/rocketmq/ClientImpl.cpp
+++ b/src/main/cpp/rocketmq/ClientImpl.cpp
@@ -409,7 +409,7 @@ void ClientImpl::onPollCommandResponse(const InvocationContext<PollCommandRespon
   absl::flat_hash_set<std::string> hosts;
   endpointsInUse(hosts);
   if (!hosts.contains(address)) {
-    SPDLOG_INFO("Endpoints={} was not used, stop to poll command.", address);
+    SPDLOG_INFO("Endpoint={} is now absent from route table. Break poll-command-cycle.", address);
     return;
   }
   if (!ctx->status.ok()) {