You are viewing a plain text version of this content. The canonical link for it is here.
Posted to commits@rocketmq.apache.org by if...@apache.org on 2020/12/29 03:36:44 UTC

[rocketmq-client-cpp] 27/29: style: fix GET_ROUTEINFO_BY_TOPIC

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

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

commit 4ace548e2af6efb013a016c539e3ffa2f93b85e6
Author: James Yin <yw...@hotmail.com>
AuthorDate: Wed Oct 21 13:02:24 2020 +0800

    style: fix GET_ROUTEINFO_BY_TOPIC
---
 src/MQClientAPIImpl.cpp    | 2 +-
 src/protocol/RequestCode.h | 2 +-
 2 files changed, 2 insertions(+), 2 deletions(-)

diff --git a/src/MQClientAPIImpl.cpp b/src/MQClientAPIImpl.cpp
index 2d35354..b25f672 100644
--- a/src/MQClientAPIImpl.cpp
+++ b/src/MQClientAPIImpl.cpp
@@ -634,7 +634,7 @@ void MQClientAPIImpl::unlockBatchMQ(const std::string& addr,
 }
 
 TopicRouteData* MQClientAPIImpl::getTopicRouteInfoFromNameServer(const std::string& topic, int timeoutMillis) {
-  RemotingCommand request(GET_ROUTEINTO_BY_TOPIC, new GetRouteInfoRequestHeader(topic));
+  RemotingCommand request(GET_ROUTEINFO_BY_TOPIC, new GetRouteInfoRequestHeader(topic));
 
   std::unique_ptr<RemotingCommand> response(remoting_client_->invokeSync(null, request, timeoutMillis));
   assert(response != nullptr);
diff --git a/src/protocol/RequestCode.h b/src/protocol/RequestCode.h
index 68b8f31..40180dd 100644
--- a/src/protocol/RequestCode.h
+++ b/src/protocol/RequestCode.h
@@ -122,7 +122,7 @@ enum MQRequestCode {
   DELETE_KV_CONFIG = 102,
   REGISTER_BROKER = 103,
   UNREGISTER_BROKER = 104,
-  GET_ROUTEINTO_BY_TOPIC = 105,
+  GET_ROUTEINFO_BY_TOPIC = 105,
   GET_BROKER_CLUSTER_INFO = 106,
   WIPE_WRITE_PERM_OF_BROKER = 205,
   GET_ALL_TOPIC_LIST_FROM_NAMESERVER = 206,